Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 41 for shutdownNow (0.1 sec)

  1. android/guava/src/com/google/common/util/concurrent/ForwardingExecutorService.java

        return delegate().isTerminated();
      }
    
      @Override
      public void shutdown() {
        delegate().shutdown();
      }
    
      @Override
      @CanIgnoreReturnValue
      public List<Runnable> shutdownNow() {
        return delegate().shutdownNow();
      }
    
      @Override
      public void execute(Runnable command) {
        delegate().execute(command);
      }
    
      @Override
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java

        mock.assertLastMethodCalled("isShutdown");
        testExecutor.shutdown();
        mock.assertLastMethodCalled("shutdown");
        List<Runnable> list = testExecutor.shutdownNow();
        mock.assertLastMethodCalled("shutdownNow");
        assertEquals(ImmutableList.of(), list);
      }
    
      public void testExecute() {
        MockExecutor mock = new MockExecutor();
        TestExecutor testExecutor = new TestExecutor(mock);
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Jul 14 14:44:08 UTC 2025
    - 9.9K bytes
    - Viewed (0)
  3. fess-crawler/src/test/java/org/codelibs/fess/crawler/interval/impl/HostIntervalControllerTest.java

                try {
                    if (!executor.awaitTermination(10, java.util.concurrent.TimeUnit.SECONDS)) {
                        executor.shutdownNow();
                    }
                } catch (final InterruptedException e) {
                    executor.shutdownNow();
                }
            }
    
            long elapsed = (System.nanoTime() - time) / 1000000;
            long wait = waittime * (numTasks - 1);
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Mon Nov 24 03:59:47 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/ForwardingExecutorService.java

        return delegate().isTerminated();
      }
    
      @Override
      public void shutdown() {
        delegate().shutdown();
      }
    
      @Override
      @CanIgnoreReturnValue
      public List<Runnable> shutdownNow() {
        return delegate().shutdownNow();
      }
    
      @Override
      public void execute(Runnable command) {
        delegate().execute(command);
      }
    
      @Override
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/MoreExecutors.java

          return delegate.isTerminated();
        }
    
        @Override
        public final void shutdown() {
          delegate.shutdown();
        }
    
        @Override
        public final List<Runnable> shutdownNow() {
          return delegate.shutdownNow();
        }
    
        /*
         * TODO: https://github.com/google/guava/issues/2143 - In addition to overriding `execute`, also
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Oct 08 18:55:33 UTC 2025
    - 45.2K bytes
    - Viewed (0)
  6. android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java

     */
    @GwtIncompatible
    public final class TestingExecutors {
      private TestingExecutors() {}
    
      /**
       * Returns a {@link ScheduledExecutorService} that never executes anything.
       *
       * <p>The {@code shutdownNow} method of the returned executor always returns an empty list despite
       * the fact that everything is still technically awaiting execution. The {@code getDelay} method
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 6.6K bytes
    - Viewed (0)
  7. src/main/java/jcifs/internal/smb2/lease/DirectoryLeaseManager.java

        public void shutdown() {
            scheduler.shutdown();
            try {
                if (!scheduler.awaitTermination(5, TimeUnit.SECONDS)) {
                    scheduler.shutdownNow();
                }
            } catch (InterruptedException e) {
                scheduler.shutdownNow();
                Thread.currentThread().interrupt();
            }
    
            // Stop all change watchers
            for (String path : directoryCache.keySet()) {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 23 01:47:47 UTC 2025
    - 12.3K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java

        mock.assertLastMethodCalled("isShutdown");
        testExecutor.shutdown();
        mock.assertLastMethodCalled("shutdown");
        List<Runnable> list = testExecutor.shutdownNow();
        mock.assertLastMethodCalled("shutdownNow");
        assertEquals(ImmutableList.of(), list);
      }
    
      public void testExecute() {
        MockExecutor mock = new MockExecutor();
        TestExecutor testExecutor = new TestExecutor(mock);
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Jul 14 14:44:08 UTC 2025
    - 9.9K bytes
    - Viewed (0)
  9. okhttp-dnsoverhttps/src/test/java/okhttp3/dnsoverhttps/TestDohMain.kt

            workingOnly = true,
            getOnly = true,
          )
        runBatch(dnsProviders, names)
      } finally {
        bootstrapClient.connectionPool.evictAll()
        bootstrapClient.dispatcher.executorService.shutdownNow()
        bootstrapClient.cache?.close()
      }
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 3.2K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

          }
        }
      }
    
      public void testDirectExecutorService_shutdownNow() {
        ExecutorService executor = newDirectExecutorService();
        assertEquals(ImmutableList.of(), executor.shutdownNow());
        assertTrue(executor.isShutdown());
      }
    
      public void testExecuteAfterShutdown() {
        ExecutorService executor = newDirectExecutorService();
        executor.shutdown();
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Dec 12 00:25:21 UTC 2025
    - 26.5K bytes
    - Viewed (0)
Back to top