Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 53 for shutdownNow (0.06 seconds)

  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
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 4.1K bytes
    - Click Count (0)
  2. 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
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jul 17 15:26:41 GMT 2025
    - 6.6K bytes
    - Click Count (0)
  3. 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);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 10.1K bytes
    - Click Count (0)
  4. 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
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jul 17 15:26:41 GMT 2025
    - 6.6K bytes
    - Click Count (0)
  5. 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);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 10.1K bytes
    - Click Count (0)
  6. 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();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 26.1K bytes
    - Click Count (0)
  7. okhttp/src/jvmTest/kotlin/okhttp3/RecordingExecutor.kt

            return
          }
        }
        throw AssertionError("No such job: $url")
      }
    
      override fun shutdown() {
        shutdown = true
      }
    
      override fun shutdownNow(): List<Runnable> = throw UnsupportedOperationException()
    
      override fun isShutdown(): Boolean = shutdown
    
      override fun isTerminated(): Boolean = throw UnsupportedOperationException()
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Mon Oct 06 18:34:01 GMT 2025
    - 2.2K bytes
    - Click Count (0)
  8. android/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
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jan 28 22:39:02 GMT 2026
    - 45.6K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/util/concurrent/DirectExecutorService.java

          if (runningTasks == 0) {
            lock.notifyAll();
          }
        }
      }
    
      // See newDirectExecutorService javadoc for unusual behavior of this method.
      @Override
      public List<Runnable> shutdownNow() {
        shutdown();
        return ImmutableList.of();
      }
    
      @Override
      public boolean isTerminated() {
        synchronized (lock) {
          return shutdown && runningTasks == 0;
        }
      }
    
      @Override
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Dec 16 14:23:59 GMT 2025
    - 3.4K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/util/concurrent/WrappingExecutorService.java

      @Override
      public final void shutdown() {
        delegate.shutdown();
      }
    
      @Override
      @CanIgnoreReturnValue
      public final List<Runnable> shutdownNow() {
        return delegate.shutdownNow();
      }
    
      @Override
      public final boolean isShutdown() {
        return delegate.isShutdown();
      }
    
      @Override
      public final boolean isTerminated() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Jul 11 18:52:30 GMT 2025
    - 5.4K bytes
    - Click Count (0)
Back to Top