- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 31 for IsTerminated (0.26 sec)
-
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/ManualEvictionInMemoryCacheTest.groovy
key } as Supplier<String>) } } executor.shutdown() executor.awaitTermination(2, TimeUnit.SECONDS) then: executor.isTerminated() concurrency.times { String key = "key${it}" assert cache.getIfPresent(key) == key } where: concurrency << [8, 16, 32] }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:08:47 UTC 2023 - 1.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/WrappingExecutorService.java
return delegate.shutdownNow(); } @Override public final boolean isShutdown() { return delegate.isShutdown(); } @Override public final boolean isTerminated() { return delegate.isTerminated(); } @Override public final boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException { return delegate.awaitTermination(timeout, unit); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 5.5K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/WrappingExecutorService.java
return delegate.shutdownNow(); } @Override public final boolean isShutdown() { return delegate.isShutdown(); } @Override public final boolean isTerminated() { return delegate.isTerminated(); } @Override public final boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException { return delegate.awaitTermination(timeout, unit); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 5.5K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java
return delegate.shutdownNow(); } @Override public boolean isShutdown() { return delegate.isShutdown(); } @Override public boolean isTerminated() { return delegate.isTerminated(); } @Override public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException { Preconditions.checkNotNull(unit, "unit must not be null!");
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Oct 06 00:47:57 UTC 2021 - 6.4K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java
return delegate.shutdownNow(); } @Override public boolean isShutdown() { return delegate.isShutdown(); } @Override public boolean isTerminated() { return delegate.isTerminated(); } @Override public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException { Preconditions.checkNotNull(unit, "unit must not be null!");
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Oct 06 00:47:57 UTC 2021 - 6.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/RecordingExecutor.kt
shutdown = true } override fun shutdownNow(): List<Runnable> { throw UnsupportedOperationException() } override fun isShutdown(): Boolean { return shutdown } override fun isTerminated(): Boolean { throw UnsupportedOperationException() } override fun awaitTermination( timeout: Long, unit: TimeUnit, ): Boolean { throw UnsupportedOperationException() }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2.1K bytes - Viewed (0) -
pkg/kubelet/pod_workers_test.go
pod1 = podWorkers.podSyncStatuses[types.UID("1-normal")] if pod1.IsTerminated() { t.Fatalf("unexpected pod state: %#v", pod1) } pod2 = podWorkers.podSyncStatuses[types.UID("2-static")] if pod2.IsTerminated() { t.Fatalf("unexpected pod state: %#v", pod2) } pod3 := podWorkers.podSyncStatuses[types.UID("3-static")] if pod3.IsTerminated() { t.Fatalf("unexpected pod state: %#v", pod3) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 75.6K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/DirectExecutorService.java
@Override public List<Runnable> shutdownNow() { shutdown(); return Collections.emptyList(); } @Override public boolean isTerminated() { synchronized (lock) { return shutdown && runningTasks == 0; } } @Override public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 15 10:40:05 UTC 2024 - 3.5K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/concurrent/TestManagedExecutor.groovy
} List<Runnable> shutdownNow() { throw new UnsupportedOperationException() } boolean isShutdown() { throw new UnsupportedOperationException() } boolean isTerminated() { throw new UnsupportedOperationException() } boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException { throw new UnsupportedOperationException() }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 2.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java
assertFalse(executor.isTerminated()); assertInterrupted(); } public void testTryAwaitTerminationInfiniteTimeout() { ExecutorService executor = newFixedThreadPool(1); requestInterruptIn(500); executor.execute(new SleepTask(1000)); executor.shutdown(); awaitTerminationUninterruptibly(executor); assertTrue(executor.isTerminated()); assertInterrupted(); } /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 10 16:06:39 UTC 2024 - 31.7K bytes - Viewed (0)