isTeminated - Code Search

okhttp/src/jvmTest/kotlin/okhttp3/RecordingExecutor.kt

  override fun shutdown() {
    shutdown = true
  }

  override fun shutdownNow(): List<Runnable> = throw UnsupportedOperationException()

  override fun isShutdown(): Boolean = shutdown

  override fun isTerminated(): Boolean = throw UnsupportedOperationException()

  override fun awaitTermination(
    timeout: Long,
    unit: TimeUnit,
  ): 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)

github.com/google/guava

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

    assertFalse(executor.isTerminated());
    assertInterrupted();
  }

  public void testTryAwaitTerminationInfiniteTimeout() {
    ExecutorService executor = newFixedThreadPool(1);
    requestInterruptIn(500);
    executor.execute(new SleepTask(1000));
    executor.shutdown();
    awaitTerminationUninterruptibly(executor);
    assertTrue(executor.isTerminated());
    assertInterrupted();
  }

  /**

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Mon Mar 16 22:45:21 GMT 2026

- 38.1K bytes

- Click Count (0)

github.com/google/guava

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

  // 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
  public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException {

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)

github.com/google/guava

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

    return delegate.shutdownNow();
  }

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

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

  @Override
  public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException {
    Preconditions.checkNotNull(unit, "unit must not be null!");

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

    return delegate.shutdownNow();
  }

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

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

  @Override
  public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException {
    Preconditions.checkNotNull(unit, "unit must not be null!");

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-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java

    assertFalse(executor.isTerminated());
    assertInterrupted();
  }

  public void testTryAwaitTerminationInfiniteTimeout() {
    ExecutorService executor = newFixedThreadPool(1);
    requestInterruptIn(500);
    executor.execute(new SleepTask(1000));
    executor.shutdown();
    awaitTerminationUninterruptibly(executor);
    assertTrue(executor.isTerminated());
    assertInterrupted();
  }

  /**

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Mon Mar 16 22:45:21 GMT 2026

- 38.1K bytes

- Click Count (0)

github.com/google/guava

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

      throw new UnsupportedOperationException();
    }

    @Override
    public boolean isShutdown() {
      throw new UnsupportedOperationException();
    }

    @Override
    public boolean isTerminated() {
      throw new UnsupportedOperationException();
    }
  }

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)

github.com/google/guava

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

      shutdown();
      return ImmutableList.of();
    }

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

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

    @Override
    public boolean awaitTermination(long timeout, TimeUnit unit) {
      return true;
    }

    @Override

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

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

    } catch (NoSuchMethodException e) {
      assertThat(isAndroid() || isBeforeJava19()).isTrue();
      return; // close() doesn't exist, so we can't test it.
    }
    closeMethod.invoke(wrapper);
    assertThat(delegate.isTerminated()).isTrue();
  }

  private static boolean isAndroid() {
    return System.getProperty("java.runtime.name", "").contains("Android");
  }

  private static boolean isBeforeJava19() {

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Sat Mar 07 02:20:33 GMT 2026

- 2.9K bytes

- Click Count (0)

github.com/google/guava

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

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

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

    @Override
    public boolean isTerminated() {
      return false;
    }

    @Override
    public boolean awaitTermination(long timeout, TimeUnit unit) {
      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)

Search Options