Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 71 - 80 of 349 for Future (0.04 seconds)

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

          ListeningExecutorService executorService, Callable<T> task, BlockingQueue<Future<T>> queue) {
        ListenableFuture<T> future = executorService.submit(task);
        future.addListener(() -> queue.add(future), directExecutor());
        return future;
      }
    
      /**
       * Returns a default thread factory used to create new threads.
       *
       * <p>When running on AppEngine with access to <a
    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. guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java

         * Future, then a call setException() would likely also overflow.
         *
         * - If the stack overflowed after set()/setValue() stored its result, then a call to
         * setException() will be a no-op because the Future is already done.
         *
         * Both scenarios are bad: The output Future might never complete, or, if it does complete, it
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Feb 20 18:03:37 GMT 2025
    - 10.8K bytes
    - Click Count (0)
  3. guava/src/com/google/common/util/concurrent/ForwardingExecutorService.java

        delegate().execute(command);
      }
    
      @Override
      public <T extends @Nullable Object> Future<T> submit(Callable<T> task) {
        return delegate().submit(task);
      }
    
      @Override
      public Future<?> submit(Runnable task) {
        return delegate().submit(task);
      }
    
      @Override
      public <T extends @Nullable Object> Future<T> submit(
          Runnable task, @ParametricNullness T result) {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 4.1K bytes
    - Click Count (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/ConnectionPool.kt

     * share the same [Address] may share a [Connection]. This class implements the policy
     * of which connections to keep open for future use.
     *
     * @constructor Create a new connection pool with tuning parameters appropriate for a single-user
     * application. The tuning parameters in this pool are subject to change in future OkHttp releases.
     * Currently this pool holds up to 5 idle connections which will be evicted after 5 minutes of
     * inactivity.
     */
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Oct 07 21:55:03 GMT 2025
    - 3.4K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

        /**
         * Contains the most recently submitted {@code Future}, which may be cancelled or updated,
         * always under a lock.
         */
        private static final class SupplantableFuture implements Cancellable {
          private final ReentrantLock lock;
    
          @GuardedBy("lock")
          private Future<@Nullable Void> currentFuture;
    
          SupplantableFuture(ReentrantLock lock, Future<@Nullable Void> currentFuture) {
            this.lock = lock;
    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)
  6. guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

        CountDownLatch latch = new CountDownLatch(1);
        SettableFuture<?> future = SettableFuture.create();
        Executor delegate =
            new Executor() {
              @Override
              public void execute(Runnable task) {
                if (future.set(null)) {
                  awaitUninterruptibly(latch);
                }
                throw new RejectedExecutionException();
    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)
  7. android/guava/src/com/google/common/util/concurrent/Platform.java

        }
      }
    
      static <V extends @Nullable Object> V get(AbstractFuture<V> future)
          throws InterruptedException, ExecutionException {
        return future.blockingGet();
      }
    
      static <V extends @Nullable Object> V get(AbstractFuture<V> future, long timeout, TimeUnit unit)
          throws InterruptedException, ExecutionException, TimeoutException {
        return future.blockingGet(timeout, unit);
      }
    
      private Platform() {}
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 2.1K bytes
    - Click Count (0)
  8. guava/src/com/google/common/util/concurrent/Platform.java

        }
      }
    
      static <V extends @Nullable Object> V get(AbstractFuture<V> future)
          throws InterruptedException, ExecutionException {
        return future.blockingGet();
      }
    
      static <V extends @Nullable Object> V get(AbstractFuture<V> future, long timeout, TimeUnit unit)
          throws InterruptedException, ExecutionException, TimeoutException {
        return future.blockingGet(timeout, unit);
      }
    
      private Platform() {}
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 2.1K bytes
    - Click Count (0)
  9. impl/maven-core/src/test/java/org/apache/maven/lifecycle/internal/stub/CompletionServiceStub.java

        }
    
        @Override
        public Future<ProjectSegment> take() throws InterruptedException {
            return null;
        }
    
        @Override
        public Future<ProjectSegment> poll() {
            return null;
        }
    
        @Override
        public Future<ProjectSegment> poll(long timeout, TimeUnit unit) throws InterruptedException {
            return null;
        }
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 2.6K bytes
    - Click Count (0)
  10. android/guava-tests/test/com/google/common/cache/CacheLoaderTest.java

    import static com.google.common.util.concurrent.Futures.immediateFuture;
    
    import com.google.common.collect.ImmutableList;
    import com.google.common.collect.ImmutableMap;
    import com.google.common.util.concurrent.ListenableFuture;
    import java.util.ArrayDeque;
    import java.util.Deque;
    import java.util.Map;
    import java.util.concurrent.Executor;
    import java.util.concurrent.Future;
    import java.util.concurrent.atomic.AtomicInteger;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Sep 30 22:03:28 GMT 2025
    - 3.8K bytes
    - Click Count (0)
Back to Top