Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 218 for ShutDown (0.1 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. cmd/logging.go

    	logger.LogOnceIf(ctx, "sftp", err, id, errKind...)
    }
    
    func shutdownLogIf(ctx context.Context, err error, errKind ...interface{}) {
    	logger.LogIf(ctx, "shutdown", err, errKind...)
    }
    
    func stsLogIf(ctx context.Context, err error, errKind ...interface{}) {
    	logger.LogIf(ctx, "sts", err, errKind...)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 03 18:49:48 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top