- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 40 for shutdownNow (0.21 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/JdkFutureAdaptersTest.java
* run. We want to see what happens when it's interrupted, not when it's * rejected. */ submitSuccessful.await(); executorService.shutdownNow(); abstractFuture.set(DATA1); assertEquals(DATA1, listenableFuture.get()); singleCallListener.waitForCall(); assertTrue(singleCallListener.wasCalled()); assertTrue(listenableFuture.isDone());
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 9.7K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/WiresharkExample.kt
Thread.sleep(1000) sendTestRequest(googleRequest) Thread.sleep(2000) } } finally { client.connectionPool.evictAll() client.dispatcher.executorService.shutdownNow() if (launch == CommandLine) { process?.destroyForcibly() } } } private fun sendTestRequest(request: Request) { try { if (this.launch != CommandLine) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.7K bytes - Viewed (1) -
src/main/java/org/codelibs/fess/rank/fusion/RankFusionProcessor.java
if (logger.isDebugEnabled()) { logger.debug("Interrupted.", e); } } finally { executorService.shutdownNow(); } } } public List<Map<String, Object>> search(final String query, final SearchRequestParams params, final OptionalThing<FessUserBean> userBean) {
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 16.5K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
} /** Returns true if no tasks have been scheduled. This runs the coordinator for confirmation. */ fun isIdle() = taskRunner.activeQueues().isEmpty() override fun close() { tasksExecutor.shutdownNow() } companion object { var instance = 0 @JvmField val assertionsEnabled: Boolean = OkHttpClient::class.java.desiredAssertionStatus() }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 12.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/ds/callback/FileListIndexUpdateCallbackImpl.java
} catch (final InterruptedException e) { if (logger.isDebugEnabled()) { logger.debug("Failed to interrupt executor.", e); } } finally { executor.shutdownNow(); } if (!deleteUrlList.isEmpty()) { deleteDocuments(); } indexUpdateCallback.commit(); } protected void deleteDocuments() {
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 16.8K bytes - Viewed (0) -
maven-compat/src/main/java/org/apache/maven/artifact/resolver/DefaultArtifactResolver.java
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu Apr 25 05:46:50 GMT 2024 - 24.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/MoreFilesTest.java
// any circumstances assertEquals(3, MoreFiles.listFiles(symlinkTarget).size()); Thread.yield(); } } finally { executor.shutdownNow(); } } } } public void testDeleteRecursively_nonDirectoryFile() throws IOException { try (FileSystem fs = newTestFileSystem(SECURE_DIRECTORY_STREAM)) {
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Jan 29 22:57:05 GMT 2024 - 27.2K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/project/DefaultProjectBuilder.java
} } }; } @Override public void close() { this.executor.shutdownNow(); } private int getParallelism(ProjectBuildingRequest request) { int parallelism = DEFAULT_BUILDER_PARALLELISM; try {
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu May 02 15:10:38 GMT 2024 - 56.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
propagateIfInstanceOf(e.getCause(), CancellationException.class); throw failureWithCause(e, "Unexpected exception"); } finally { executor.shutdownNow(); // TODO(cpovirk): assertTrue(awaitTerminationUninterruptibly(executor, 10, SECONDS)); } } /**
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 144.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
propagateIfInstanceOf(e.getCause(), CancellationException.class); throw failureWithCause(e, "Unexpected exception"); } finally { executor.shutdownNow(); // TODO(cpovirk): assertTrue(awaitTerminationUninterruptibly(executor, 10, SECONDS)); } } /**
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 144.5K bytes - Viewed (0)