isShutdown - Code Search

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

    return delegate().invokeAny(tasks, timeout, unit);
  }

  @Override
  public boolean isShutdown() {
    return delegate().isShutdown();
  }

  @Override
  public boolean isTerminated() {
    return delegate().isTerminated();
  }

  @Override
  public void shutdown() {
    delegate().shutdown();
  }

  @Override
  @CanIgnoreReturnValue
  public List<Runnable> shutdownNow() {

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)

github.com/google/guava

guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java

    assertFalse(testExecutor.isTerminated());
    mock.assertLastMethodCalled("isTerminated");
    assertFalse(testExecutor.isShutdown());
    mock.assertLastMethodCalled("isShutdown");
    testExecutor.shutdown();
    mock.assertLastMethodCalled("shutdown");
    List<Runnable> list = testExecutor.shutdownNow();
    mock.assertLastMethodCalled("shutdownNow");
    assertEquals(ImmutableList.of(), list);
  }

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)

github.com/google/guava

android/guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java

    assertFalse(testExecutor.isTerminated());
    mock.assertLastMethodCalled("isTerminated");
    assertFalse(testExecutor.isShutdown());
    mock.assertLastMethodCalled("isShutdown");
    testExecutor.shutdown();
    mock.assertLastMethodCalled("shutdown");
    List<Runnable> list = testExecutor.shutdownNow();
    mock.assertLastMethodCalled("shutdownNow");
    assertEquals(ImmutableList.of(), list);
  }

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)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt

   */
  @Throws(IOException::class)
  fun shutdown(statusCode: ErrorCode) {
    writer.withLock {
      val lastGoodStreamId: Int
      withLock {
        if (isShutdown) {
          return
        }
        isShutdown = true
        lastGoodStreamId = this.lastGoodStreamId
      }
      // TODO: propagate exception message into debugData.

Created: Fri Apr 03 11:42:14 GMT 2026

- Last Modified: Tue Jan 27 09:00:39 GMT 2026

- 31.9K bytes

- Click Count (0)

github.com/google/guava

guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java

    private volatile boolean shutdown;

    @Override
    public void shutdown() {
      shutdown = true;
    }

    @Override
    public List<Runnable> shutdownNow() {
      shutdown();
      return ImmutableList.of();
    }

    @Override
    public boolean isShutdown() {
      return shutdown;
    }

    @Override
    public boolean isTerminated() {

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)

github.com/google/guava

android/guava-tests/test/com/google/common/util/concurrent/AbstractListeningExecutorServiceTest.java

  /** Simple same thread listening executor service that doesn't handle shutdown. */
  private static class TestListeningExecutorService extends AbstractListeningExecutorService {

    @Override
    public void execute(Runnable runnable) {
      assertThat(runnable).isInstanceOf(TrustedListenableFutureTask.class);
      runnable.run();
    }

    @Override
    public void shutdown() {}

    @Override
    public List<Runnable> shutdownNow() {

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)

github.com/google/guava

guava-tests/test/com/google/common/util/concurrent/AbstractListeningExecutorServiceTest.java

  /** Simple same thread listening executor service that doesn't handle shutdown. */
  private static class TestListeningExecutorService extends AbstractListeningExecutorService {

    @Override
    public void execute(Runnable runnable) {
      assertThat(runnable).isInstanceOf(TrustedListenableFutureTask.class);
      runnable.run();
    }

    @Override
    public void shutdown() {}

    @Override
    public List<Runnable> shutdownNow() {

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)

github.com/google/guava

android/guava/src/com/google/common/util/concurrent/WrappingExecutorService.java

  // The remaining methods just delegate.

  @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)

github.com/google/guava

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)

github.com/google/guava

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)

Search Options