Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 1,401 for futuna (0.2 sec)

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

       *
       * @param <V1> the type returned by the first future
       * @param <V2> the type returned by the second future
       * @param <V3> the type returned by the third future
       * @param <V4> the type returned by the fourth future
       * @param <V5> the type returned by the fifth future
       */
      public static final class Combiner5<
              V1 extends @Nullable Object,
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue May 07 12:37:15 UTC 2024
    - 98.3K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java

      }
    
      /**
       * Invokes {@code future.}{@link Future#get() get()} uninterruptibly.
       *
       * <p>Similar methods:
       *
       * <ul>
       *   <li>To retrieve a result from a {@code Future} that is already done, use {@link
       *       Futures#getDone Futures.getDone}.
       *   <li>To treat {@link InterruptedException} uniformly with other exceptions, use {@link
       *       Futures#getChecked(Future, Class) Futures.getChecked}.
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 14.4K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/FuturesGetCheckedInputs.java

      static final Future<String> FAILED_FUTURE_ERROR = immediateFailedFuture(ERROR);
      static final Future<String> RUNTIME_EXCEPTION_FUTURE =
          UncheckedThrowingFuture.throwingRuntimeException(RUNTIME_EXCEPTION);
      static final Future<String> ERROR_FUTURE = UncheckedThrowingFuture.throwingError(ERROR);
    
      public static final class TwoArgConstructorException extends Exception {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Sep 06 13:46:56 UTC 2023
    - 6.2K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/WrappingScheduledExecutorServiceTest.java

        }
    
        @Override
        public <T> Future<T> submit(Callable<T> task) {
          throw new UnsupportedOperationException();
        }
    
        @Override
        public Future<?> submit(Runnable task) {
          throw new UnsupportedOperationException();
        }
    
        @Override
        public <T> Future<T> submit(Runnable task, T result) {
          throw new UnsupportedOperationException();
        }
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Dec 16 19:54:45 UTC 2020
    - 7.6K bytes
    - Viewed (0)
  5. 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)
  6. 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: Wed Sep 06 17:04:31 UTC 2023
    - 7.4K bytes
    - Viewed (0)
  7. tests/integration/security/sds_ingress/quic/ingress_test.go

    			// currently VM does not work in this test
    			err := ingressutil.SetupTest(ctx, &customConfig, namespace.Future(&echo1NS))
    			if err != nil {
    				return err
    			}
    			return nil
    		}).
    		Setup(deployment.SetupSingleNamespace(&apps, deployment.Config{
    			Namespaces: []namespace.Getter{
    				namespace.Future(&echo1NS),
    			},
    			Configs: echo.ConfigFuture(&customConfig),
    		})).
    		Setup(func(ctx resource.Context) error {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 08 22:02:59 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  8. 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;
        }
      }
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Feb 13 14:28:25 UTC 2024
    - 16.8K bytes
    - Viewed (0)
  9. 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: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 4.1K bytes
    - Viewed (0)
  10. subprojects/core/src/testFixtures/groovy/org/gradle/util/internal/MockExecutor.java

        }
    
        @Override
        public <T> Future<T> submit(Callable<T> task) {
            throw new UnsupportedOperationException();
        }
    
        @Override
        public <T> Future<T> submit(Runnable task, T result) {
            throw new UnsupportedOperationException();
        }
    
        @Override
        public Future<?> submit(Runnable task) {
            throw new UnsupportedOperationException();
        }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed Apr 07 08:18:49 UTC 2021
    - 4.4K bytes
    - Viewed (0)
Back to top