Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 25 for shutdownNow (0.07 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. 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)
  4. 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)
  5. 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)
  6. 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)
  7. android/guava-tests/test/com/google/common/util/concurrent/AbstractListeningExecutorServiceTest.java

          assertThat(runnable).isInstanceOf(TrustedListenableFutureTask.class);
          runnable.run();
        }
    
        @Override
        public void shutdown() {}
    
        @Override
        public List<Runnable> shutdownNow() {
          return ImmutableList.of();
        }
    
        @Override
        public boolean isShutdown() {
          return false;
        }
    
        @Override
        public boolean isTerminated() {
          return false;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 3.4K bytes
    - Click Count (0)
  8. guava-tests/test/com/google/common/util/concurrent/AbstractListeningExecutorServiceTest.java

          assertThat(runnable).isInstanceOf(TrustedListenableFutureTask.class);
          runnable.run();
        }
    
        @Override
        public void shutdown() {}
    
        @Override
        public List<Runnable> shutdownNow() {
          return ImmutableList.of();
        }
    
        @Override
        public boolean isShutdown() {
          return false;
        }
    
        @Override
        public boolean isTerminated() {
          return false;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 3.4K bytes
    - Click Count (0)
  9. guava-tests/test/com/google/common/util/concurrent/ListeningExecutorServiceTest.java

          throw new UnsupportedOperationException();
        }
    
        @Override
        public void shutdown() {
          throw new UnsupportedOperationException();
        }
    
        @Override
        public List<Runnable> shutdownNow() {
          throw new UnsupportedOperationException();
        }
    
        @Override
        public boolean isShutdown() {
          throw new UnsupportedOperationException();
        }
    
        @Override
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 4.6K bytes
    - Click Count (0)
  10. android/guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java

      private final ListeningExecutorService delegate = newDirectExecutorService();
    
      @Override
      public void shutdown() {
        delegate.shutdown();
      }
    
      @Override
      public List<Runnable> shutdownNow() {
        return delegate.shutdownNow();
      }
    
      @Override
      public boolean isShutdown() {
        return delegate.isShutdown();
      }
    
      @Override
      public boolean isTerminated() {
        return delegate.isTerminated();
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:37:28 GMT 2025
    - 6.5K bytes
    - Click Count (0)
Back to Top