- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for executorService (0.2 sec)
-
android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
* ExecutorService#shutdownNow()} and returns. * * @param service the {@code ExecutorService} to shut down * @param timeout the maximum time to wait for the {@code ExecutorService} to terminate * @param unit the time unit of the timeout argument * @return {@code true} if the {@code ExecutorService} was terminated successfully, {@code false}
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Apr 17 16:33:44 GMT 2024 - 41.8K bytes - Viewed (0) -
src/main/java/org/codelibs/core/timer/TimeoutManager.java
try { executorService.shutdown(); executorService.awaitTermination(60, TimeUnit.SECONDS); } catch (final InterruptedException e) { if (logger.isDebugEnabled()) { logger.debug("Interrupted.", e); } } finally { executorService.shutdownNow(); } } }
Java - Registered: Fri May 03 20:58:11 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 8K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/WebSocketEcho.java
.url("ws://echo.websocket.org") .build(); client.newWebSocket(request, this); // Trigger shutdown of the dispatcher's executor so this process exits immediately. client.dispatcher().executorService().shutdown(); } @Override public void onOpen(WebSocket webSocket, Response response) { webSocket.send("Hello..."); webSocket.send("...World!"); webSocket.send(ByteString.decodeHex("deadbeef"));
Java - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 04 11:40:21 GMT 2024 - 1.6K bytes - Viewed (0) -
maven-compat/src/main/java/org/apache/maven/artifact/resolver/DefaultArtifactResolver.java
Thread.currentThread().setContextClassLoader(old); } } } @Override public void dispose() { if (executor instanceof ExecutorService) { ((ExecutorService) executor).shutdownNow(); } }
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) -
maven-core/src/main/java/org/apache/maven/project/DefaultProjectBuilder.java
private final ReactorModelPool modelPool; private final ConcurrentMap<String, Object> parentCache; private final ModelTransformerContextBuilder transformerContextBuilder; private final ExecutorService executor; private final ModelCache modelCache; BuildSession(ProjectBuildingRequest request, boolean localProjects) { this.request = request; this.session =
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/src/com/google/common/util/concurrent/Futures.java
AsyncCallable<O> callable, long delay, TimeUnit timeUnit, ScheduledExecutorService executorService) { TrustedListenableFutureTask<O> task = TrustedListenableFutureTask.create(callable); Future<?> scheduled = executorService.schedule(task, delay, timeUnit); /* * Even when the user interrupts the task, we pass `false` to `cancel` so that we don't
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 59.6K bytes - Viewed (0)