Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for ExecutionList (0.2 sec)

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

     * @author Sven Mawson
     * @since 1.0
     */
    @J2ktIncompatible
    @GwtIncompatible
    @ElementTypesAreNonnullByDefault
    public final class ExecutionList {
      /** Logger to log exceptions caught when running runnables. */
      private static final LazyLogger log = new LazyLogger(ExecutionList.class);
    
      /**
       * The runnable, executor pairs to execute. This acts as a stack threaded through the {@link
       * RunnableExecutorPair#next} field.
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 22 21:17:24 GMT 2024
    - 6.9K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/ExecutionListTest.java

    import java.util.concurrent.atomic.AtomicInteger;
    import junit.framework.TestCase;
    
    /**
     * Unit tests for {@link ExecutionList}.
     *
     * @author Nishant Thakkar
     * @author Sven Mawson
     */
    public class ExecutionListTest extends TestCase {
    
      private final ExecutionList list = new ExecutionList();
    
      public void testRunOnPopulatedList() throws Exception {
        Executor exec = Executors.newCachedThreadPool();
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Feb 09 22:57:07 GMT 2022
    - 4.7K bytes
    - Viewed (0)
  3. 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
       */
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 04 09:45:04 GMT 2023
    - 4.3K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java

            Executors.newCachedThreadPool(threadFactory);
    
        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);
    
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Dec 14 20:35:03 GMT 2023
    - 7.5K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/util/concurrent/ExecutionListTest.java

    import java.util.concurrent.atomic.AtomicInteger;
    import junit.framework.TestCase;
    
    /**
     * Unit tests for {@link ExecutionList}.
     *
     * @author Nishant Thakkar
     * @author Sven Mawson
     */
    public class ExecutionListTest extends TestCase {
    
      private final ExecutionList list = new ExecutionList();
    
      public void testRunOnPopulatedList() throws Exception {
        Executor exec = Executors.newCachedThreadPool();
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Feb 09 22:57:07 GMT 2022
    - 4.7K bytes
    - Viewed (0)
  6. 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
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed May 09 15:17:25 GMT 2018
    - 13.6K bytes
    - Viewed (0)
  7. 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
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Apr 06 12:56:11 GMT 2023
    - 13.6K bytes
    - Viewed (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
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 17 15:19:38 GMT 2023
    - 20.4K bytes
    - Viewed (0)
  9. 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
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Mon Apr 17 15:19:38 GMT 2023
    - 20.4K bytes
    - Viewed (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).
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Feb 20 17:00:05 GMT 2024
    - 144.5K bytes
    - Viewed (0)
Back to top