Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 23 for directExecutor (0.13 sec)

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

        CountingRunnable after = new CountingRunnable();
    
        future.addListener(before, directExecutor());
        future.setFuture(delegate);
        future.addListener(inBetween, directExecutor());
        delegate.set(1);
        future.addListener(after, directExecutor());
    
        before.assertRun();
        inBetween.assertRun();
        after.assertRun();
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 15.4K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/ExecutionListTest.java

        @Override
        public void run() {
          countDownLatch.countDown();
        }
      }
    
      public void testExceptionsCaught() {
        list.add(THROWING_RUNNABLE, directExecutor());
        list.execute();
        list.add(THROWING_RUNNABLE, directExecutor());
      }
    
      public void testNulls() {
        new NullPointerTester().testAllPublicInstanceMethods(new ExecutionList());
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 4.7K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/FutureCallbackTest.java

                }
              }
            };
        addCallback(f, callback, directExecutor());
        f.cancel(true);
      }
    
      public void testThrowErrorFromGet() {
        Error error = new AssertionError("ASSERT!");
        ListenableFuture<String> f = UncheckedThrowingFuture.throwingError(error);
        MockCallback callback = new MockCallback(error);
        addCallback(f, callback, directExecutor());
      }
    
      public void testRuntimeExceptionFromGet() {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Jul 14 14:44:08 UTC 2025
    - 6.7K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

                  }
                },
                directExecutor()));
        thingToCancel[0] = serializer.submit(Callables.returning(null), directExecutor());
        results.add(thingToCancel[0]);
        // Enqueue more than enough tasks to force reentrancy.
        for (int i = 0; i < 5; i++) {
          results.add(serializer.submit(Callables.returning(null), directExecutor()));
        }
    
        manualExecutorTask[0].run();
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 20:58:01 UTC 2025
    - 16.1K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/util/concurrent/FutureCallbackTest.java

                }
              }
            };
        addCallback(f, callback, directExecutor());
        f.cancel(true);
      }
    
      public void testThrowErrorFromGet() {
        Error error = new AssertionError("ASSERT!");
        ListenableFuture<String> f = UncheckedThrowingFuture.throwingError(error);
        MockCallback callback = new MockCallback(error);
        addCallback(f, callback, directExecutor());
      }
    
      public void testRuntimeExceptionFromGet() {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Jul 14 14:44:08 UTC 2025
    - 6.7K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/FluentFuture.java

       *         },
       *         directExecutor());
       * }
       *
       * <p>When selecting an executor, note that {@code directExecutor} is dangerous in some cases. See
       * the discussion in the {@link #addListener} documentation. All its warnings about heavyweight
       * listeners are also applicable to heavyweight functions passed to this method. (Specifically,
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 19.7K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/ExecutionListTest.java

        @Override
        public void run() {
          countDownLatch.countDown();
        }
      }
    
      public void testExceptionsCaught() {
        list.add(THROWING_RUNNABLE, directExecutor());
        list.execute();
        list.add(THROWING_RUNNABLE, directExecutor());
      }
    
      public void testNulls() {
        new NullPointerTester().testAllPublicInstanceMethods(new ExecutionList());
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 4.7K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java

        queue.addListener(listener1, directExecutor());
    
        Multiset<Object> counters = ConcurrentHashMultiset.create();
        queue.enqueue(incrementingEvent(counters, listener1, 1));
        queue.enqueue(incrementingEvent(counters, listener1, 2));
    
        Object listener2 = new Object();
        queue.addListener(listener2, directExecutor());
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java

        queue.addListener(listener1, directExecutor());
    
        Multiset<Object> counters = ConcurrentHashMultiset.create();
        queue.enqueue(incrementingEvent(counters, listener1, 1));
        queue.enqueue(incrementingEvent(counters, listener1, 2));
    
        Object listener2 = new Object();
        queue.addListener(listener2, directExecutor());
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/FluentFutureTest.java

    import static com.google.common.util.concurrent.Futures.immediateFailedFuture;
    import static com.google.common.util.concurrent.Futures.immediateFuture;
    import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
    import static java.util.concurrent.Executors.newScheduledThreadPool;
    import static java.util.concurrent.TimeUnit.SECONDS;
    import static org.junit.Assert.assertThrows;
    
    import com.google.common.annotations.GwtCompatible;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 5.8K bytes
    - Viewed (0)
Back to top