Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 507 for Futures (0.19 sec)

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

       *
       * <p>Cancelling a delegate future propagates to input futures once all the delegates complete,
       * either from cancellation or because an input future has completed. If N futures are passed in,
       * and M delegates are cancelled, the remaining M input futures will be cancelled once N - M of
       * the input futures complete. If all the delegates are cancelled, all the input futures will be
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 01 16:15:01 GMT 2024
    - 59.6K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

        SettableFuture<Object> future1 = SettableFuture.create();
        SettableFuture<Object> future2 = SettableFuture.create();
        SettableFuture<Object> future3 = SettableFuture.create();
        ListenableFuture<List<Object>> all = allAsList(future1, future2, future3);
    
        future1.setException(new MyException());
        future2.setException(new MyException());
        future3.setException(new MyException());
    
        try {
    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)
  3. guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

        SettableFuture<Object> future1 = SettableFuture.create();
        SettableFuture<Object> future2 = SettableFuture.create();
        SettableFuture<Object> future3 = SettableFuture.create();
        ListenableFuture<List<Object>> all = allAsList(future1, future2, future3);
    
        future1.setException(new MyException());
        future2.setException(new MyException());
        future3.setException(new MyException());
    
        try {
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Tue Feb 20 17:00:05 GMT 2024
    - 144.5K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

        private final ListenableFuture<@Nullable Void> future;
        private boolean called = false;
    
        private TestCallable(ListenableFuture<@Nullable Void> future) {
          this.future = future;
        }
    
        @Override
        public ListenableFuture<@Nullable Void> call() throws Exception {
          called = true;
          return future;
        }
      }
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 16.8K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

        private final ListenableFuture<@Nullable Void> future;
        private boolean called = false;
    
        private TestCallable(ListenableFuture<@Nullable Void> future) {
          this.future = future;
        }
    
        @Override
        public ListenableFuture<@Nullable Void> call() throws Exception {
          called = true;
          return future;
        }
      }
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 16.8K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

        }
    
        private final ClosingFuture<V1> future1;
        private final ClosingFuture<V2> future2;
        private final ClosingFuture<V3> future3;
    
        private Combiner3(
            ClosingFuture<V1> future1, ClosingFuture<V2> future2, ClosingFuture<V3> future3) {
          super(true, ImmutableList.of(future1, future2, future3));
          this.future1 = future1;
          this.future2 = future2;
          this.future3 = future3;
        }
    
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 01 16:15:01 GMT 2024
    - 98.5K bytes
    - Viewed (0)
  7. futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java

     * result. (If you want such access, you may prefer {@link Futures#addCallback
     * Futures.addCallback}.) Still, direct {@code addListener} calls are occasionally useful:
     *
     * <pre>{@code
     * final String name = ...;
     * inFlight.add(name);
     * ListenableFuture<Result> future = service.query(name);
     * future.addListener(new Runnable() {
     *   public void run() {
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Jun 26 21:13:41 GMT 2023
    - 8K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/AggregateFuture.java

      protected final void afterDone() {
        super.afterDone();
    
        ImmutableCollection<? extends Future<?>> localFutures = futures;
        releaseResources(OUTPUT_FUTURE_DONE); // nulls out `futures`
    
        if (isCancelled() & localFutures != null) {
          boolean wasInterrupted = wasInterrupted();
          for (Future<?> future : localFutures) {
            future.cancel(wasInterrupted);
          }
        }
        /*
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 15.4K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java

          List<Future<String>> futures = testExecutor.invokeAll(tasks);
          mock.assertLastMethodCalled("invokeAll");
          checkResults(futures);
        }
        {
          MockExecutor mock = new MockExecutor();
          TimeUnit unit = TimeUnit.SECONDS;
          long timeout = 5;
          TestExecutor testExecutor = new TestExecutor(mock);
          List<Future<String>> futures = testExecutor.invokeAll(tasks, timeout, unit);
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Jan 05 19:41:03 GMT 2023
    - 9.8K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/FuturesGetChecked.java

      @CanIgnoreReturnValue
      @ParametricNullness
      static <V extends @Nullable Object, X extends Exception> V getChecked(
          Future<V> future, Class<X> exceptionClass) throws X {
        return getChecked(bestGetCheckedTypeValidator(), future, exceptionClass);
      }
    
      /** Implementation of {@link Futures#getChecked(Future, Class)}. */
      @CanIgnoreReturnValue
      @VisibleForTesting
      @ParametricNullness
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Dec 14 20:35:03 GMT 2023
    - 10.3K bytes
    - Viewed (0)
Back to top