Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 4,110 for futures (0.13 sec)

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

          ImmutableCollection<? extends ListenableFuture<?>> futures,
          boolean allMustSucceed,
          Executor listenerExecutor,
          AsyncCallable<V> callable) {
        super(futures, allMustSucceed, false);
        this.task = new AsyncCallableInterruptibleTask(callable, listenerExecutor);
        init();
      }
    
      CombinedFuture(
          ImmutableCollection<? extends ListenableFuture<?>> futures,
          boolean allMustSucceed,
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/CombinedFuture.java

          ImmutableCollection<? extends ListenableFuture<?>> futures,
          boolean allMustSucceed,
          Executor listenerExecutor,
          AsyncCallable<V> callable) {
        super(futures, allMustSucceed, false);
        this.task = new AsyncCallableInterruptibleTask(callable, listenerExecutor);
        init();
      }
    
      CombinedFuture(
          ImmutableCollection<? extends ListenableFuture<?>> futures,
          boolean allMustSucceed,
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/ListeningExecutorServiceTest.java

     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.truth.Truth.assertThat;
    import static com.google.common.util.concurrent.Futures.immediateFailedFuture;
    import static com.google.common.util.concurrent.Futures.immediateFuture;
    import static java.util.concurrent.TimeUnit.NANOSECONDS;
    
    import java.time.Duration;
    import java.util.Collection;
    import java.util.Collections;
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 02 12:45:23 UTC 2023
    - 4.5K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/AtomicLongMapBasherTest.java

        final AtomicLongMap<String> map = AtomicLongMap.create();
    
        ExecutorService threadPool = Executors.newFixedThreadPool(nThreads);
        ArrayList<Future<Long>> futures = new ArrayList<>();
        for (int i = 0; i < nTasks; i++) {
          futures.add(
              threadPool.submit(
                  new Callable<Long>() {
                    @Override
                    public Long call() {
                      long threadSum = 0;
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Feb 13 14:28:25 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  5. guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/GwtFuturesCatchingSpecialization.java

    import java.util.concurrent.Executor;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
     * Hidden superclass of {@link Futures} that provides us a place to declare special GWT versions of
     * the {@link Futures#catching(ListenableFuture, Class, com.google.common.base.Function)
     * Futures.catching} family of methods. Those versions have slightly different signatures.
     */
    @ElementTypesAreNonnullByDefault
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Thu Dec 08 20:30:27 UTC 2022
    - 2K bytes
    - Viewed (0)
  6. maven-core/src/test/java/org/apache/maven/lifecycle/internal/builder/multithreaded/ThreadOutputMuxerTest.java

            List<Future<ProjectSegment>> futures = new ArrayList<>();
            for (ProjectSegment projectBuild : projectBuildList) {
                final Future<ProjectSegment> buildFuture =
                        service.submit(new Outputter(threadOutputMuxer, projectBuild, lyrics.next()));
                futures.add(buildFuture);
            }
    
            for (Future<ProjectSegment> future : futures) {
                future.get();
    Registered: Wed Jun 12 09:55:16 UTC 2024
    - Last Modified: Wed Sep 06 08:39:32 UTC 2023
    - 6.6K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/FuturesTransformTest.java

     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.util.concurrent.Futures.transform;
    import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
    
    import com.google.common.base.Function;
    import java.lang.reflect.UndeclaredThrowableException;
    
    /**
     * Unit tests for {@link Futures#transform(ListenableFuture, Function, Executor)}.
     *
     * @author Nishant Thakkar
     */
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Thu Jun 28 16:27:15 UTC 2018
    - 1.9K bytes
    - Viewed (0)
  8. fess-crawler/src/test/java/org/codelibs/fess/crawler/interval/impl/HostIntervalControllerTest.java

            // Callableタスク(複数)を実行する
            final ExecutorService executor = Executors.newFixedThreadPool(numTasks);
            try {
                final List<Future<Integer>> futures = executor.invokeAll(tasks);
                for (final Future<Integer> future : futures) {
                    future.get();
                }
            } catch (final InterruptedException e) {
                // no thing to do
            } catch (final ExecutionException e) {
    Registered: Wed Jun 12 15:17:51 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/FuturesTransformTest.java

     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.util.concurrent.Futures.transform;
    import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
    
    import com.google.common.base.Function;
    import java.lang.reflect.UndeclaredThrowableException;
    
    /**
     * Unit tests for {@link Futures#transform(ListenableFuture, Function, Executor)}.
     *
     * @author Nishant Thakkar
     */
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Thu Jun 28 16:27:15 UTC 2018
    - 1.9K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/Partially.java

     * {@code GwtIncompatible}. This is more accurate for {@link Futures#catching}, which is available
     * under GWT but with a slightly different signature.
     *
     * <p>We can't use {@code PartiallyGwtIncompatible} because then the GWT compiler wouldn't recognize
     * it as a {@code GwtIncompatible} annotation. And for {@code Futures.catching}, we need the GWT
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 05 22:27:35 UTC 2021
    - 1.9K bytes
    - Viewed (0)
Back to top