- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for shutdown (0.2 sec)
-
android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
private final Object lock = new Object(); /* * Conceptually, these two variables describe the executor being in * one of three states: * - Active: shutdown == false * - Shutdown: runningTasks > 0 and shutdown == true * - Terminated: runningTasks == 0 and shutdown == true */ @GuardedBy("lock")
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) -
samples/guide/src/main/java/okhttp3/recipes/WebSocketEcho.java
Request request = new Request.Builder() .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!");
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) -
build-logic/cleanup/src/main/java/gradlebuild/cleanup/services/KillLeakingJavaProcesses.java
pkill(pid); }); } else { forEachLeakingJavaProcess(rootProjectDir, (pid, line) -> { System.out.println("A process wasn't shutdown properly in a previous Gradle run. Killing process with PID " + pid + ": " + line); pkill(pid); }); } } private static void initExecutionMode(String[] args) {
Java - Registered: Wed May 01 11:36:15 GMT 2024 - Last Modified: Fri Apr 26 09:46:00 GMT 2024 - 11.3K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/project/ProjectModelResolver.java
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu Apr 25 14:13:36 GMT 2024 - 15.8K bytes - Viewed (0) -
src/main/java/org/codelibs/core/timer/TimeoutManager.java
if (logger.isDebugEnabled()) { logger.debug("TimeoutManagerThread stopped."); } thread = null; try { executorService.shutdown(); executorService.awaitTermination(60, TimeUnit.SECONDS); } catch (final InterruptedException e) { if (logger.isDebugEnabled()) {
Java - Registered: Fri May 03 20:58:11 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/SystemHelper.java
public void destroy() { shutdownHookList.forEach(action -> { try { action.run(); } catch (final Exception e) { logger.warn("Failed to process shutdown task.", e); } }); } public String getUsername() { final RequestManager requestManager = ComponentUtil.getRequestManager();
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Sat Apr 13 11:43:03 GMT 2024 - 26.5K bytes - Viewed (2) -
maven-api-impl/src/test/java/org/apache/maven/internal/impl/standalone/RepositorySystemSupplier.java
* repository system instance needed, new instance of this class must be created. For proper shut down of returned * repository system instance(s) use {@link RepositorySystem#shutdown()} method on supplied instance(s). * <p> * Since Resolver 2.0 this class offers access to various components via public getters, and allows even partial object * graph construction. * <p>
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu May 02 15:10:38 GMT 2024 - 43.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/LocalCacheTest.java
threadAboutToBlockForRefresh.set(Thread.currentThread()); assertThat(cache.getOrLoad("test")).isEqualTo("testReload"); } finally { refreshExecutor.shutdown(); } } public void testSetRemovalListener() { RemovalListener<Object, Object> testListener = TestingRemovalListeners.nullRemovalListener(); LocalCache<Object, Object> map =
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Thu Mar 14 23:06:48 GMT 2024 - 112.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/LocalCacheTest.java
threadAboutToBlockForRefresh.set(Thread.currentThread()); assertThat(cache.getOrLoad("test")).isEqualTo("testReload"); } finally { refreshExecutor.shutdown(); } } public void testSetRemovalListener() { RemovalListener<Object, Object> testListener = TestingRemovalListeners.nullRemovalListener(); LocalCache<Object, Object> map =
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Mar 14 23:06:48 GMT 2024 - 110.7K bytes - Viewed (0)