Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 359 for Callable (0.16 sec)

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

       * <p>Cancellation does not propagate from the output future to a callable that has begun to
       * execute, but if the output future is cancelled before {@link Callable#call()} is invoked,
       * {@link Callable#call()} will not be invoked.
       */
      public <T extends @Nullable Object> ListenableFuture<T> submit(
          Callable<T> callable, Executor executor) {
        checkNotNull(callable);
        checkNotNull(executor);
        return submitAsync(
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 22.1K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java

        }
      }
    
      private static List<Callable<String>> createTasks(int n) {
        List<Callable<String>> callables = Lists.newArrayList();
        for (int i = 0; i < n; i++) {
          callables.add(Callables.returning(RESULT_VALUE + i));
        }
        return callables;
      }
    
      private static final class WrappedCallable<T> implements Callable<T> {
        private final Callable<T> delegate;
    
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Thu Jan 05 19:41:03 GMT 2023
    - 9.8K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

              }
            };
    
        results.add(serializer.submit(Callables.returning(null), manualExecutor));
        final Future<?>[] thingToCancel = new Future<?>[1];
        results.add(
            serializer.submit(
                new Callable<@Nullable Void>() {
                  @Override
                  public @Nullable Void call() {
                    thingToCancel[0].cancel(false);
                    return null;
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 16.8K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

              }
            };
    
        results.add(serializer.submit(Callables.returning(null), manualExecutor));
        final Future<?>[] thingToCancel = new Future<?>[1];
        results.add(
            serializer.submit(
                new Callable<@Nullable Void>() {
                  @Override
                  public @Nullable Void call() {
                    thingToCancel[0].cancel(false);
                    return null;
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 16.8K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java

        }
      }
    
      private static List<Callable<String>> createTasks(int n) {
        List<Callable<String>> callables = Lists.newArrayList();
        for (int i = 0; i < n; i++) {
          callables.add(Callables.returning(RESULT_VALUE + i));
        }
        return callables;
      }
    
      private static final class WrappedCallable<T> implements Callable<T> {
        private final Callable<T> delegate;
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Jan 05 19:41:03 GMT 2023
    - 9.8K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        Callable<@Nullable Void> cancelRunnable =
            new Callable<@Nullable Void>() {
              @Override
              public @Nullable Void call() {
                cancellationSuccess.set(currentFuture.get().cancel(true));
                awaitUnchecked(barrier);
                return null;
              }
            };
        Callable<@Nullable Void> setFutureCompleteSuccessfullyRunnable =
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 46.8K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        List<Callable<T>> tasks = ImmutableList.of();
        List<? extends Future<?>> unused = executor.invokeAll(tasks);
      }
    
      public void testListeningDecorator() throws Exception {
        ListeningExecutorService service = listeningDecorator(newDirectExecutorService());
        assertSame(service, listeningDecorator(service));
        List<Callable<String>> callables = ImmutableList.of(Callables.returning("x"));
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 28.2K bytes
    - Viewed (3)
  8. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        Callable<@Nullable Void> cancelRunnable =
            new Callable<@Nullable Void>() {
              @Override
              public @Nullable Void call() {
                cancellationSuccess.set(currentFuture.get().cancel(true));
                awaitUnchecked(barrier);
                return null;
              }
            };
        Callable<@Nullable Void> setFutureCompleteSuccessfullyRunnable =
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 46.8K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        List<Callable<T>> tasks = ImmutableList.of();
        List<? extends Future<?>> unused = executor.invokeAll(tasks);
      }
    
      public void testListeningDecorator() throws Exception {
        ListeningExecutorService service = listeningDecorator(newDirectExecutorService());
        assertSame(service, listeningDecorator(service));
        List<Callable<String>> callables = ImmutableList.of(Callables.returning("x"));
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 28.2K bytes
    - Viewed (0)
  10. analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/references/KDocReferenceResolver.kt

            fun create(packageParts: List<Name>, classParts: List<Name>, callable: Name?): FqNameInterpretation {
                val packageName = FqName.fromSegments(packageParts.map { it.asString() })
                val relativeClassName = FqName.fromSegments(classParts.map { it.asString() })
    
                return when {
                    classParts.isEmpty() && callable == null -> FqNameInterpretationAsPackage(packageName)
    Plain Text
    - Registered: Fri Apr 26 08:18:10 GMT 2024
    - Last Modified: Fri Apr 19 11:06:47 GMT 2024
    - 22.6K bytes
    - Viewed (0)
Back to top