Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 86 for listenablefuture (0.69 sec)

  1. guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java

        return delegate.awaitTermination(timeout, unit);
      }
    
      @Override
      public <T> ListenableFuture<T> submit(Callable<T> task) {
        Preconditions.checkNotNull(task, "task must not be null!");
        return delegate.submit(task);
      }
    
      @Override
      public <T> ListenableFuture<T> submit(Runnable task, T result) {
        Preconditions.checkNotNull(task, "task must not be null!");
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:37:28 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/Futures.java

      @SafeVarargs
      public static <V extends @Nullable Object> ListenableFuture<List<V>> allAsList(
          ListenableFuture<? extends V>... futures) {
        ListenableFuture<List<@Nullable V>> nullable =
            new ListFuture<V>(ImmutableList.copyOf(futures), true);
        // allAsList ensures that it fills the output list with V instances.
        @SuppressWarnings("nullness")
        ListenableFuture<List<V>> nonNull = nullable;
        return nonNull;
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 64.3K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/ListeningExecutorService.java

    public interface ListeningExecutorService extends ExecutorService {
      /**
       * @return a {@code ListenableFuture} representing pending completion of the task
       * @throws RejectedExecutionException {@inheritDoc}
       */
      @Override
      <T extends @Nullable Object> ListenableFuture<T> submit(Callable<T> task);
    
      /**
       * @return a {@code ListenableFuture} representing pending completion of the task
       * @throws RejectedExecutionException {@inheritDoc}
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java

              public Class<?> loadClass(String name) throws ClassNotFoundException {
                if (name.startsWith(concurrentPackage)
                    // Use other classloader for ListenableFuture, so that the objects can interact
                    && !ListenableFuture.class.getName().equals(name)) {
                  synchronized (loadedClasses) {
                    Class<?> toReturn = loadedClasses.get(name);
                    if (toReturn == null) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java

              public Class<?> loadClass(String name) throws ClassNotFoundException {
                if (name.startsWith(concurrentPackage)
                    // Use other classloader for ListenableFuture, so that the objects can interact
                    && !ListenableFuture.class.getName().equals(name)) {
                  synchronized (loadedClasses) {
                    Class<?> toReturn = loadedClasses.get(name);
                    if (toReturn == null) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

      private static final class TestCallable implements AsyncCallable<@Nullable Void> {
    
        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;
        }
      }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 20:58:01 UTC 2025
    - 16.1K bytes
    - Viewed (0)
  7. futures/listenablefuture1/pom.xml

        - If users want only ListenableFuture, they depend on listenablefuture-1.0.
    
        - If users want all of Guava, they depend on guava, which, as of Guava
        27.0, depends on
        listenablefuture-9999.0-empty-to-avoid-conflict-with-guava. The 9999.0-...
        version number is enough for some build systems (notably, Gradle) to select
        that empty artifact over the "real" listenablefuture-1.0 -- avoiding a
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Sep 12 21:42:09 UTC 2018
    - 2.2K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/AbstractListeningExecutorService.java

      @Override
      public ListenableFuture<?> submit(Runnable task) {
        return (ListenableFuture<?>) super.submit(task);
      }
    
      @CanIgnoreReturnValue // TODO(kak): consider removing this
      @Override
      public <T extends @Nullable Object> ListenableFuture<T> submit(
          Runnable task, @ParametricNullness T result) {
        return (ListenableFuture<T>) super.submit(task, result);
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Feb 12 17:47:46 UTC 2025
    - 3K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java

       * #setFuture(ListenableFuture)}.
       */
      private static final class AsyncTransformFuture<
              I extends @Nullable Object, O extends @Nullable Object>
          extends AbstractTransformFuture<
              I, O, AsyncFunction<? super I, ? extends O>, ListenableFuture<? extends O>> {
        AsyncTransformFuture(
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Feb 20 18:03:37 UTC 2025
    - 10.8K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/ForwardingListenableFuture.java

       * already constructed {@link ListenableFuture} as the delegate.
       *
       * @since 9.0
       */
      public abstract static class SimpleForwardingListenableFuture<V extends @Nullable Object>
          extends ForwardingListenableFuture<V> {
        private final ListenableFuture<V> delegate;
    
        protected SimpleForwardingListenableFuture(ListenableFuture<V> delegate) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 2.3K bytes
    - Viewed (0)
Back to top