Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for SequentialExecutor (0.09 sec)

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

    import static com.google.common.util.concurrent.SequentialExecutor.WorkerRunningState.IDLE;
    import static com.google.common.util.concurrent.SequentialExecutor.WorkerRunningState.QUEUED;
    import static com.google.common.util.concurrent.SequentialExecutor.WorkerRunningState.QUEUING;
    import static com.google.common.util.concurrent.SequentialExecutor.WorkerRunningState.RUNNING;
    import static java.lang.System.identityHashCode;
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/SequentialExecutor.java

    import static com.google.common.util.concurrent.SequentialExecutor.WorkerRunningState.IDLE;
    import static com.google.common.util.concurrent.SequentialExecutor.WorkerRunningState.QUEUED;
    import static com.google.common.util.concurrent.SequentialExecutor.WorkerRunningState.QUEUING;
    import static com.google.common.util.concurrent.SequentialExecutor.WorkerRunningState.RUNNING;
    import static java.lang.System.identityHashCode;
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

          }
        }
      }
    
      private FakeExecutor fakePool;
      private SequentialExecutor e;
    
      @Override
      public void setUp() {
        fakePool = new FakeExecutor();
        e = new SequentialExecutor(fakePool);
      }
    
      public void testConstructingWithNullExecutor_fails() {
        assertThrows(NullPointerException.class, () -> new SequentialExecutor(null));
      }
    
      public void testBasics() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

          }
        }
      }
    
      private FakeExecutor fakePool;
      private SequentialExecutor e;
    
      @Override
      public void setUp() {
        fakePool = new FakeExecutor();
        e = new SequentialExecutor(fakePool);
      }
    
      public void testConstructingWithNullExecutor_fails() {
        assertThrows(NullPointerException.class, () -> new SequentialExecutor(null));
      }
    
      public void testBasics() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/ListenerCallQueue.java

       * A special purpose queue/executor that dispatches listener events serially on a configured
       * executor. Each event can be added and dispatched as separate phases.
       *
       * <p>This class is very similar to {@link SequentialExecutor} with the exception that events can
       * be added without necessarily executing immediately.
       */
      private static final class PerListenerQueue<L> implements Runnable {
        final L listener;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Dec 13 19:45:20 UTC 2023
    - 8.2K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/MoreExecutors.java

       * Executors#newSingleThreadExecutor}).
       *
       * @since 23.3 (since 23.1 as {@code sequentialExecutor})
       */
      @GwtIncompatible
      public static Executor newSequentialExecutor(Executor delegate) {
        return new SequentialExecutor(delegate);
      }
    
      /**
       * Creates an {@link ExecutorService} whose {@code submit} and {@code invokeAll} methods submit
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 44.1K bytes
    - Viewed (0)
Back to top