- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 41 for shutdownNow (0.1 sec)
-
android/guava/src/com/google/common/util/concurrent/ForwardingExecutorService.java
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 4.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java
mock.assertLastMethodCalled("isShutdown"); testExecutor.shutdown(); mock.assertLastMethodCalled("shutdown"); List<Runnable> list = testExecutor.shutdownNow(); mock.assertLastMethodCalled("shutdownNow"); assertEquals(ImmutableList.of(), list); } public void testExecute() { MockExecutor mock = new MockExecutor(); TestExecutor testExecutor = new TestExecutor(mock);
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Jul 14 14:44:08 UTC 2025 - 9.9K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/interval/impl/HostIntervalControllerTest.java
try { if (!executor.awaitTermination(10, java.util.concurrent.TimeUnit.SECONDS)) { executor.shutdownNow(); } } catch (final InterruptedException e) { executor.shutdownNow(); } } long elapsed = (System.nanoTime() - time) / 1000000; long wait = waittime * (numTasks - 1);Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Mon Nov 24 03:59:47 UTC 2025 - 11.4K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ForwardingExecutorService.java
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 4.1K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/MoreExecutors.java
return delegate.isTerminated(); } @Override public final void shutdown() { delegate.shutdown(); } @Override public final List<Runnable> shutdownNow() { return delegate.shutdownNow(); } /* * TODO: https://github.com/google/guava/issues/2143 - In addition to overriding `execute`, also
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Wed Oct 08 18:55:33 UTC 2025 - 45.2K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java
*/ @GwtIncompatible public final class TestingExecutors { private TestingExecutors() {} /** * Returns a {@link ScheduledExecutorService} that never executes anything. * * <p>The {@code shutdownNow} method of the returned executor always returns an empty list despite * the fact that everything is still technically awaiting execution. The {@code getDelay} methodRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Jul 17 15:26:41 UTC 2025 - 6.6K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/lease/DirectoryLeaseManager.java
public void shutdown() { scheduler.shutdown(); try { if (!scheduler.awaitTermination(5, TimeUnit.SECONDS)) { scheduler.shutdownNow(); } } catch (InterruptedException e) { scheduler.shutdownNow(); Thread.currentThread().interrupt(); } // Stop all change watchers for (String path : directoryCache.keySet()) {
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 23 01:47:47 UTC 2025 - 12.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java
mock.assertLastMethodCalled("isShutdown"); testExecutor.shutdown(); mock.assertLastMethodCalled("shutdown"); List<Runnable> list = testExecutor.shutdownNow(); mock.assertLastMethodCalled("shutdownNow"); assertEquals(ImmutableList.of(), list); } public void testExecute() { MockExecutor mock = new MockExecutor(); TestExecutor testExecutor = new TestExecutor(mock);
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Jul 14 14:44:08 UTC 2025 - 9.9K bytes - Viewed (0) -
okhttp-dnsoverhttps/src/test/java/okhttp3/dnsoverhttps/TestDohMain.kt
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 3.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
} } } public void testDirectExecutorService_shutdownNow() { ExecutorService executor = newDirectExecutorService(); assertEquals(ImmutableList.of(), executor.shutdownNow()); assertTrue(executor.isShutdown()); } public void testExecuteAfterShutdown() { ExecutorService executor = newDirectExecutorService(); executor.shutdown();Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Fri Dec 12 00:25:21 UTC 2025 - 26.5K bytes - Viewed (0)