Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 1,210 for futuna (0.12 sec)

  1. 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
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Thu Feb 22 17:40:56 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  2. android/guava-testlib/test/com/google/common/testing/GcFinalizationTest.java

        final SettableFuture<@Nullable Void> future = SettableFuture.create();
        Object x =
            new Object() {
              @Override
              protected void finalize() {
                future.set(null);
              }
            };
        x = null; // Hint to the JIT that x is unreachable
        GcFinalization.awaitDone(future);
        assertTrue(future.isDone());
        assertFalse(future.isCancelled());
      }
    
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Jun 10 19:21:11 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  3. src/cmd/vendor/golang.org/x/tools/internal/versions/features.go

    	Go1_21 = "go1.21"
    	Go1_22 = "go1.22"
    )
    
    // Future is an invalid unknown Go version sometime in the future.
    // Do not use directly with Compare.
    const Future = ""
    
    // AtLeast reports whether the file version v comes after a Go release.
    //
    // Use this predicate to enable a behavior once a certain Go release
    // has happened (and stays enabled in the future).
    func AtLeast(v, release string) bool {
    	if v == Future {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 02 02:20:05 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/SimpleTimeLimiter.java

        checkNotNull(timeoutUnit);
        checkPositiveTimeout(timeoutDuration);
    
        Future<T> future = executor.submit(callable);
    
        try {
          return amInterruptible
              ? future.get(timeoutDuration, timeoutUnit)
              : getUninterruptibly(future, timeoutDuration, timeoutUnit);
        } catch (InterruptedException e) {
          future.cancel(true);
          throw e;
        } catch (ExecutionException e) {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Jun 27 14:21:11 UTC 2023
    - 9.7K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

     *       Future} is "completed" even if it is cancelled while its underlying work continues on a
     *       thread, an RPC, etc. The {@code Future} is also "completed" if it fails "early" -- for
     *       example, if the deadline expires on a {@code Future} returned from {@link
     *       Futures#withTimeout} while the {@code Future} it wraps continues its underlying work. So
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java

          MockExecutor mock = new MockExecutor();
          TestExecutor testExecutor = new TestExecutor(mock);
          Future<?> f = testExecutor.submit(doNothing());
          mock.assertLastMethodCalled("submit");
          f.get();
        }
        {
          MockExecutor mock = new MockExecutor();
          TestExecutor testExecutor = new TestExecutor(mock);
          Future<String> f = testExecutor.submit(doNothing(), RESULT_VALUE);
          mock.assertLastMethodCalled("submit");
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Thu Jan 05 19:41:03 UTC 2023
    - 9.8K bytes
    - Viewed (0)
  7. futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java

    import java.util.concurrent.Executor;
    import java.util.concurrent.Future;
    import java.util.concurrent.RejectedExecutionException;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
     * A {@link Future} that accepts completion listeners. Each listener has an associated executor, and
     * it is invoked using this executor once the future's computation is {@linkplain Future#isDone()
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Jun 26 21:13:41 UTC 2023
    - 8K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/ListenableFuture.java

    import java.util.concurrent.Executor;
    import java.util.concurrent.Future;
    import java.util.concurrent.RejectedExecutionException;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
     * A {@link Future} that accepts completion listeners. Each listener has an associated executor, and
     * it is invoked using this executor once the future's computation is {@linkplain Future#isDone()
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Jun 26 21:13:41 UTC 2023
    - 8K bytes
    - Viewed (0)
  9. src/cmd/go/testdata/script/gotoolchain_modcmds.txt

    # the go.mod file to record a specific, stable toolchain version that can.
    
    ! go mod verify
    stderr '^go: rsc.io/future@v1.0.0: module rsc.io/future@v1.0.0 requires go >= 1.999 \(running go 1.21.0\)'
    
    ! go mod graph
    stderr '^go: rsc.io/future@v1.0.0: module rsc.io/future@v1.0.0 requires go >= 1.999 \(running go 1.21.0\)'
    
    # TODO(#64008): 'go mod download' without arguments should fail too.
    
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Nov 08 19:32:39 UTC 2023
    - 1.3K bytes
    - Viewed (0)
  10. maven-core/src/test/java/org/apache/maven/lifecycle/internal/stub/CompletionServiceStub.java

                projectBuildFutureTask.run();
            }
            return projectBuildFutureTask;
        }
    
        public Future<ProjectSegment> take() throws InterruptedException {
            return null;
        }
    
        public Future<ProjectSegment> poll() {
            return null;
        }
    
        public Future<ProjectSegment> poll(long timeout, TimeUnit unit) throws InterruptedException {
            return null;
        }
    Registered: Wed Jun 12 09:55:16 UTC 2024
    - Last Modified: Wed Sep 06 08:39:32 UTC 2023
    - 2.6K bytes
    - Viewed (0)
Back to top