Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 11 for ExecutionList (0.1 seconds)

  1. android/guava/src/com/google/common/util/concurrent/ExecutionList.java

     *
     * @author Nishant Thakkar
     * @author Sven Mawson
     * @since 1.0
     */
    @GwtIncompatible
    public final class ExecutionList {
      /** Logger to log exceptions caught when running runnables. */
      private static final LazyLogger log = new LazyLogger(ExecutionList.class);
    
      private final Object lock = new Object();
    
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Feb 10 11:51:21 GMT 2026
    - 6.9K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/util/concurrent/ListenableFutureTask.java

      // such as BoundedQueueExecutorService to allow extends but it would be nice to make it final to
      // avoid unintended usage.
    
      // The execution list to hold our listeners.
      private final ExecutionList executionList = new ExecutionList();
    
      /**
       * Creates a {@code ListenableFutureTask} that will upon running, execute the given {@code
       * Callable}.
       *
       * @param callable the callable task
       * @since 10.0
       */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Feb 10 11:51:21 GMT 2026
    - 4.2K bytes
    - Click Count (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/ExecutionListTest.java

    import org.jspecify.annotations.NullUnmarked;
    
    /**
     * Unit tests for {@link ExecutionList}.
     *
     * @author Nishant Thakkar
     * @author Sven Mawson
     */
    @NullUnmarked
    @GwtIncompatible
    @J2ktIncompatible
    public class ExecutionListTest extends TestCase {
    
      private final ExecutionList list = new ExecutionList();
    
      public void testRunOnPopulatedList() throws Exception {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 4.4K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java

        private final Executor adapterExecutor;
    
        // The execution list to hold our listeners.
        private final ExecutionList executionList = new ExecutionList();
    
        // This allows us to only start up a thread waiting on the delegate future when the first
        // listener is added.
        private final AtomicBoolean hasListeners = new AtomicBoolean(false);
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jul 17 15:26:41 GMT 2025
    - 7.5K bytes
    - Click Count (0)
  5. guava-tests/benchmark/com/google/common/util/concurrent/ExecutionListBenchmark.java

        Object getImpl();
      }
    
      enum Impl {
        NEW {
          @Override
          ExecutionListWrapper newExecutionList() {
            return new ExecutionListWrapper() {
              final ExecutionList list = new ExecutionList();
    
              @Override
              public void add(Runnable runnable, Executor executor) {
                list.add(runnable, executor);
              }
    
              @Override
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jul 16 17:42:14 GMT 2025
    - 15.8K bytes
    - Click Count (0)
  6. guava-tests/test/com/google/common/util/concurrent/ExecutionListTest.java

    import org.jspecify.annotations.NullUnmarked;
    
    /**
     * Unit tests for {@link ExecutionList}.
     *
     * @author Nishant Thakkar
     * @author Sven Mawson
     */
    @NullUnmarked
    @GwtIncompatible
    @J2ktIncompatible
    public class ExecutionListTest extends TestCase {
    
      private final ExecutionList list = new ExecutionList();
    
      public void testRunOnPopulatedList() throws Exception {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 4.4K bytes
    - Click Count (0)
  7. guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java

        /** Synchronization control for AbstractFutures. */
        private final Sync<V> sync = new Sync<V>();
    
        // The execution list to hold our executors.
        private final ExecutionList executionList = new ExecutionList();
    
        /** Constructor for use by subclasses. */
        protected OldAbstractFuture() {}
    
        /*
         * Improve the documentation of when InterruptedException is thrown. Our
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 13.8K bytes
    - Click Count (0)
  8. android/guava-tests/benchmark/com/google/common/util/concurrent/ExecutionListBenchmark.java

        Object getImpl();
      }
    
      enum Impl {
        NEW {
          @Override
          ExecutionListWrapper newExecutionList() {
            return new ExecutionListWrapper() {
              final ExecutionList list = new ExecutionList();
    
              @Override
              public void add(Runnable runnable, Executor executor) {
                list.add(runnable, executor);
              }
    
              @Override
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jul 16 17:42:14 GMT 2025
    - 15.8K bytes
    - Click Count (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java

        /** Synchronization control for AbstractFutures. */
        private final Sync<V> sync = new Sync<V>();
    
        // The execution list to hold our executors.
        private final ExecutionList executionList = new ExecutionList();
    
        /** Constructor for use by subclasses. */
        protected OldAbstractFuture() {}
    
        /*
         * Improve the documentation of when InterruptedException is thrown. Our
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 13.8K bytes
    - Click Count (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

       */
      @J2ktIncompatible
      @GwtIncompatible // reflection
      public void testTransformExceptionRemainsMemoized() throws Throwable {
        // We need to test with two input futures since ExecutionList.execute
        // doesn't catch Errors and we cannot depend on the order that our
        // transformations run. (So it is possible that the Error being thrown
        // could prevent our second transformations from running).
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 134K bytes
    - Click Count (0)
Back to Top