Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 395 for executor (0.04 seconds)

  1. guava/src/com/google/common/util/concurrent/MoreExecutors.java

      }
    
      /**
       * Returns an {@link Executor} that runs each task executed sequentially, such that no two tasks
       * are running concurrently.
       *
       * <p>{@linkplain Executor#execute executed} tasks have a happens-before order as defined in the
       * Java Language Specification. Tasks execute with the same happens-before order that the function
       * calls to {@link Executor#execute execute()} that submitted those tasks had.
       *
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Oct 08 18:55:33 GMT 2025
    - 45.2K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

          /** The future that represents the next execution of this task. */
          @GuardedBy("lock")
          private @Nullable SupplantableFuture cancellationDelegate;
    
          ReschedulableCallable(
              AbstractService service, ScheduledExecutorService executor, Runnable runnable) {
            this.wrappedRunnable = runnable;
            this.executor = executor;
            this.service = service;
          }
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sat Aug 09 01:14:59 GMT 2025
    - 27.7K bytes
    - Click Count (0)
  3. android/guava-tests/benchmark/com/google/common/util/concurrent/ExecutionListBenchmark.java

          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 "
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Jul 16 17:42:14 GMT 2025
    - 15.8K bytes
    - Click Count (0)
  4. impl/maven-core/src/test/java/org/apache/maven/lifecycle/internal/builder/multithreaded/SmartProjectComparatorTest.java

            int numThreads = 10;
            int numIterations = 100;
            ExecutorService executor = Executors.newFixedThreadPool(numThreads);
            CountDownLatch latch = new CountDownLatch(numThreads);
            AtomicReference<Exception> exception = new AtomicReference<>();
    
            for (int i = 0; i < numThreads; i++) {
                executor.submit(() -> {
                    try {
                        for (int j = 0; j < numIterations; j++) {
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Wed Aug 06 12:03:40 GMT 2025
    - 8.9K bytes
    - Click Count (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java

          assertEquals(Service.State.STOPPING, state());
          shutdownCalled++;
        }
    
        @Override
        protected Executor executor() {
          return executor;
        }
    
        @Override
        public void tearDown() throws Exception {
          executor.shutdown();
        }
      }
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Oct 28 16:03:47 GMT 2025
    - 12.9K bytes
    - Click Count (0)
  6. android/guava-tests/benchmark/com/google/common/util/concurrent/AbstractFutureFootprintBenchmark.java

    import com.google.common.util.concurrent.AbstractFutureBenchmarks.Facade;
    import com.google.common.util.concurrent.AbstractFutureBenchmarks.Impl;
    import java.util.HashSet;
    import java.util.Set;
    import java.util.concurrent.Executor;
    import org.jspecify.annotations.NullUnmarked;
    
    /** Measures the size of AbstractFuture implementations. */
    @NullUnmarked
    public class AbstractFutureFootprintBenchmark {
    
      enum State {
        NOT_DONE,
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 18:46:00 GMT 2025
    - 3K bytes
    - Click Count (0)
  7. guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

        assertEquals(0, numCalls.get());
        reject.set(false);
        executor.execute(task);
        assertEquals(1, numCalls.get());
      }
    
      /*
       * Under Android, MyError propagates up and fails the test?
       *
       * TODO(b/218700094): Does this matter to prod users, or is it just a feature of our testing
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Fri Jul 11 18:52:30 GMT 2025
    - 11.4K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/util/concurrent/FluentFuture.java

       *     returned future.
       * @param executor Executor to run the function in.
       * @return A future that holds result of the transformation.
       */
      public final <T extends @Nullable Object> FluentFuture<T> transform(
          Function<? super V, T> function, Executor executor) {
        return (FluentFuture<T>) Futures.transform(this, function, executor);
      }
    
      /**
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 19.7K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java

       */
      public static <V extends @Nullable Object> ListenableFuture<V> listenInPoolThread(
          Future<V> future, Executor executor) {
        checkNotNull(executor);
        if (future instanceof ListenableFuture) {
          return (ListenableFuture<V>) future;
        }
        return new ListenableFutureAdapter<>(future, executor);
      }
    
      /**
       * An adapter to turn a {@link Future} into a {@link ListenableFuture}. This will wait on the
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Jul 17 15:26:41 GMT 2025
    - 7.5K bytes
    - Click Count (0)
  10. guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java

          assertEquals(Service.State.STOPPING, state());
          shutdownCalled++;
        }
    
        @Override
        protected Executor executor() {
          return executor;
        }
    
        @Override
        public void tearDown() throws Exception {
          executor.shutdown();
        }
      }
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Oct 28 16:03:47 GMT 2025
    - 12.9K bytes
    - Click Count (0)
Back to Top