Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 388 for FUTURE (0.03 sec)

  1. 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: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Jul 14 14:44:08 UTC 2025
    - 9.9K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/FuturesGetChecked.java

      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
      static <V extends @Nullable Object, X extends Exception> V getChecked(
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 11.8K bytes
    - Viewed (0)
  3. 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;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.8K bytes
    - Viewed (0)
  4. android/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) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  5. src/test/java/jcifs/tests/persistent/HandleReconnectorTest.java

            TestHandleReconnector testReconnector = new TestHandleReconnector(mockManager, true);
    
            CompletableFuture<HandleInfo> future = testReconnector.reconnectHandle("/test/file.txt", new IOException("Network error"));
    
            HandleInfo result = future.get();
            assertNotNull(result);
            assertEquals(testHandle, result);
    
            verify(mockManager).completeReconnect("/test/file.txt", true);
        }
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 04:51:33 UTC 2025
    - 5.6K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/AsyncCallable.java

     * result.
     *
     * @since 20.0
     */
    @FunctionalInterface
    @GwtCompatible
    public interface AsyncCallable<V extends @Nullable Object> {
      /**
       * Computes a result {@code Future}. The output {@code Future} need not be {@linkplain
       * Future#isDone done}, making {@code AsyncCallable} suitable for asynchronous derivations.
       *
       * <p>Throwing an exception from this method is equivalent to returning a failing {@link
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 1.5K 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.jspecify.annotations.NullMarked;
    import org.jspecify.annotations.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: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 8K bytes
    - Viewed (0)
  8. src/test/java/jcifs/SmbWatchHandleTest.java

            try {
                Future<List<FileNotifyInformation>> future = executor.submit(() -> blockingHandle.watch());
    
                // Verify timeout occurs
                assertThrows(TimeoutException.class, () -> {
                    future.get(100, TimeUnit.MILLISECONDS);
                });
    
                // Cancel the future
                future.cancel(true);
            } finally {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 13.2K bytes
    - Viewed (0)
  9. 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.jspecify.annotations.NullMarked;
    import org.jspecify.annotations.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: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 8K bytes
    - Viewed (0)
  10. src/main/java/jcifs/internal/smb2/lease/DirectoryChangeNotifier.java

            /**
             * Gets the future for asynchronous notification completion
             * @return the notification future
             */
            public CompletableFuture<Void> getNotificationFuture() {
                return notificationFuture;
            }
    
            /**
             * Sets the future for asynchronous notification completion
             * @param future the notification future to set
             */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 13.7K bytes
    - Viewed (0)
Back to top