- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 218 for ShutDown (0.1 sec)
-
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()) {
Registered: Fri Nov 01 20:58:10 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 8K bytes - Viewed (0) -
src/test/java/jcifs/tests/WatchTest.java
this.base = createTestDirectory(); } @Override @After public void tearDown () throws Exception { if ( this.executor != null ) { this.executor.shutdown(); if ( this.future != null ) { this.future.cancel(true); } this.executor.awaitTermination(1, TimeUnit.SECONDS); } if ( this.base != null ) {
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 8.4K bytes - Viewed (0) -
cmd/mrf.go
return } select { case m.opCh <- op: default: } } // Do not accept new MRF operations anymore and start to save // the current heal status in one available disk func (m *mrfState) shutdown() { atomic.StoreInt32(&m.closing, 1) m.wg.Wait() close(m.opCh) atomic.StoreInt32(&m.closed, 1) if len(m.opCh) > 0 {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 13 22:26:05 UTC 2024 - 6.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache2/RelayTest.kt
private lateinit var file: File @BeforeEach fun setUp() { file = File(tempDir, "test") } @AfterEach fun tearDown() { executor.shutdown() } @Test fun singleSource() { val upstream = Buffer() upstream.writeUtf8("abcdefghijklm") val relay = edit(file, upstream, metadata, 1024) val source = relay.newSource()
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 8.1K bytes - Viewed (0) -
cmd/logging.go
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jul 03 18:49:48 UTC 2024 - 7.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/CacheBuilderTest.java
assertEquals(expectedKeys, Sets.union(cache.asMap().keySet(), removalNotifications.keySet())); assertTrue(Sets.intersection(cache.asMap().keySet(), removalNotifications.keySet()).isEmpty()); threadPool.shutdown(); threadPool.awaitTermination(300, SECONDS); } /** * Calls get() repeatedly from many different threads, and tests that all of the removed entries
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 15:00:32 UTC 2024 - 24.9K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt
} } catch (ae: AssertionError) { result += ae } if (result != null) throw result } private fun releaseClient() { testClient?.dispatcher?.executorService?.shutdown() } @SuppressLint("NewApi") private fun ExtensionContext.isFlaky(): Boolean { return (testMethod.orElseGet { null }?.isAnnotationPresent(Flaky::class.java) == true) ||
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 10.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java
* that once the Thread returns to the Executor that this Executor composes, the interruption * will still be present. If the composed Executor is an ExecutorService, it can respond to * shutdown() by returning tasks queued on that Thread after {@link #worker} drains the queue. */ @SuppressWarnings("CatchingUnchecked") // sneaky checked exception private void workOnQueue() {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 10.6K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/SequentialExecutor.java
* that once the Thread returns to the Executor that this Executor composes, the interruption * will still be present. If the composed Executor is an ExecutorService, it can respond to * shutdown() by returning tasks queued on that Thread after {@link #worker} drains the queue. */ @SuppressWarnings("CatchingUnchecked") // sneaky checked exception private void workOnQueue() {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 10.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/sso/aad/AzureAdAuthenticator.java
return result; } catch (final Exception e) { throw new SsoLoginException("Failed to get a token.", e); } finally { if (service != null) { service.shutdown(); } } } protected AuthenticationResult getAccessToken(final AuthorizationCode authorizationCode, final String currentUri) {
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 28.2K bytes - Viewed (0)