Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 60 for execute (0.15 sec)

  1. android/guava-tests/benchmark/com/google/common/util/concurrent/ExecutionListBenchmark.java

          final Runnable runnable;
          final Executor executor;
    
          RunnableExecutorPair(Runnable runnable, Executor executor) {
            this.runnable = runnable;
            this.executor = executor;
          }
    
          void execute() {
            try {
              executor.execute(runnable);
            } catch (RuntimeException e) {
              log.log(
                  Level.SEVERE,
                  "RuntimeException while executing runnable "
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Apr 17 15:19:38 GMT 2023
    - 20.4K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java

    import java.util.Deque;
    import java.util.concurrent.Executor;
    import java.util.concurrent.RejectedExecutionException;
    import java.util.logging.Level;
    import javax.annotation.CheckForNull;
    
    /**
     * Executor ensuring that all Runnables submitted are executed in order, using the provided
     * Executor, and sequentially such that no two will ever be running at the same time.
     *
     * <p>Tasks submitted to {@link #execute(Runnable)} are executed in FIFO order.
     *
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 10.6K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

                  }
                }
              };
          executor.execute(errorTask);
          service.execute(barrierTask); // submit directly to the service
          // the barrier task runs after the error task so we know that the error has been observed by
          // SequentialExecutor by the time the barrier is satisfied
          barrier.await(1, TimeUnit.SECONDS);
          executor.execute(barrierTask);
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 11.4K bytes
    - Viewed (0)
  4. guava-testlib/src/com/google/common/collect/testing/AbstractIteratorTester.java

          new IteratorOperation() {
            @Override
            public @Nullable Object execute(Iterator<?> iterator) {
              iterator.remove();
              return null;
            }
          };
    
      private static final IteratorOperation NEXT_METHOD =
          new IteratorOperation() {
            @Override
            public @Nullable Object execute(Iterator<?> iterator) {
              return iterator.next();
            }
          };
    
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 01 16:15:01 GMT 2024
    - 21.3K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/Service.java

       * one of the listener's callbacks will execute at once. However, multiple listeners' callbacks
       * may execute concurrently, and listeners may execute in an order different from the one in which
       * they were registered.
       *
       * <p>RuntimeExceptions thrown by a listener will be caught and logged. Any exception thrown
       * during {@code Executor.execute} (e.g., a {@code RejectedExecutionException}) will be caught and
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 04 09:45:04 GMT 2023
    - 10.7K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/MoreExecutors.java

       * calls to {@link Executor#execute `execute()`} that submitted those tasks had.
       *
       * <p>The executor uses {@code delegate} in order to {@link Executor#execute execute} each task in
       * turn, and does not create any threads of its own.
       *
       * <p>After execution begins on a thread from the {@code delegate} {@link Executor}, tasks are
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Apr 17 16:33:44 GMT 2024
    - 41.8K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

        @CheckForNull Executor delegate;
    
        /**
         * Set before calling delegate.execute(); set to null once run, so that it can be GCed; this
         * object may live on after, if submitAsync returns an incomplete future.
         */
        @CheckForNull Runnable task;
    
        /** Thread that called execute(). Set in execute, cleared when delegate.execute() returns. */
        @CheckForNull @LazyInit Thread submitting;
    
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 22.1K bytes
    - Viewed (0)
  8. android/guava-testlib/src/com/google/common/collect/testing/AbstractIteratorTester.java

          new IteratorOperation() {
            @Override
            public @Nullable Object execute(Iterator<?> iterator) {
              iterator.remove();
              return null;
            }
          };
    
      private static final IteratorOperation NEXT_METHOD =
          new IteratorOperation() {
            @Override
            public @Nullable Object execute(Iterator<?> iterator) {
              return iterator.next();
            }
          };
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Apr 01 16:15:01 GMT 2024
    - 20.7K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

                  }
                }
              };
          executor.execute(errorTask);
          service.execute(barrierTask); // submit directly to the service
          // the barrier task runs after the error task so we know that the error has been observed by
          // SequentialExecutor by the time the barrier is satisfied
          barrier.await(1, TimeUnit.SECONDS);
          executor.execute(barrierTask);
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 11.4K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

              public String get(long time, TimeUnit unit) {
                throw new CancellationException(); // BAD!!
              }
    
              @Override
              public void addListener(Runnable runnable, Executor executor) {
                executor.execute(runnable);
              }
            };
        future.setFuture(badFuture);
        ExecutionException expected = getExpectingExecutionException(future);
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 46.8K bytes
    - Viewed (0)
Back to top