Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 6 of 6 for ListeningScheduledExecutorService (0.14 seconds)

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

      private Runnable recordedCommand;
      private long recordedDelay;
      private long recordedInterval;
      private TimeUnit recordedTimeUnit;
    
      private final ListeningScheduledExecutorService executorService = new FakeExecutorService();
    
      public void testScheduleRunnable() throws Exception {
        Runnable command = () -> {};
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 6.5K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/util/concurrent/MoreExecutors.java

       * ListeningScheduledExecutorService}, it is returned untouched, and the rest of this
       * documentation does not apply.
       *
       * @since 10.0
       */
      @GwtIncompatible // TODO
      public static ListeningScheduledExecutorService listeningDecorator(
          ScheduledExecutorService delegate) {
        return (delegate instanceof ListeningScheduledExecutorService)
            ? (ListeningScheduledExecutorService) delegate
    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)
  3. android/guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java

    import static java.util.concurrent.TimeUnit.MILLISECONDS;
    import static org.junit.Assert.assertThrows;
    
    import com.google.common.collect.ImmutableList;
    import com.google.common.util.concurrent.ListeningScheduledExecutorService;
    import java.util.List;
    import java.util.concurrent.Callable;
    import java.util.concurrent.CancellationException;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.Future;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 3.3K bytes
    - Click Count (0)
  4. guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java

    import static java.util.concurrent.TimeUnit.MILLISECONDS;
    import static org.junit.Assert.assertThrows;
    
    import com.google.common.collect.ImmutableList;
    import com.google.common.util.concurrent.ListeningScheduledExecutorService;
    import java.util.List;
    import java.util.concurrent.Callable;
    import java.util.concurrent.CancellationException;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.Future;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 3.3K bytes
    - Click Count (0)
  5. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

            new ScheduledThreadPoolExecutor(1) {
              @Override
              protected void afterExecute(Runnable r, Throwable t) {
                completed.countDown();
              }
            };
        ListeningScheduledExecutorService service = listeningDecorator(delegate);
        ListenableFuture<Integer> future = service.schedule(Callables.returning(42), 1, MILLISECONDS);
    
        /*
    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)
  6. android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

            new ScheduledThreadPoolExecutor(1) {
              @Override
              protected void afterExecute(Runnable r, Throwable t) {
                completed.countDown();
              }
            };
        ListeningScheduledExecutorService service = listeningDecorator(delegate);
        ListenableFuture<Integer> future = service.schedule(Callables.returning(42), 1, MILLISECONDS);
    
        /*
    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)
Back to Top