| /external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| D | WrappingExecutorServiceTest.java | 87 Callable<String> task = Callables.returning(RESULT_VALUE); in testSubmit() local
99 List<Future<String>> futures = testExecutor.invokeAll(tasks); in testInvokeAll() local
108 List<Future<String>> futures = testExecutor.invokeAll(tasks, timeout, unit); in testInvokeAll() local
134 private static void checkResults(List<Future<String>> futures) in checkResults()
272 public <T> Future<T> submit(Callable<T> task) { in submit()
279 public Future<?> submit(Runnable task) { in submit()
286 public <T> Future<T> submit(Runnable task, T result) { in submit()
|
| D | MoreExecutorsTest.java | 159 List<Future<Integer>> futures = executor.invokeAll(Collections.nCopies(10, incrementTask)); in testDirectExecutorServiceInvokeAll() local
346 Runnable task = in testListeningDecorator_noWrapExecuteTask() local
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | WrappingExecutorServiceTest.java | 87 Callable<String> task = Callables.returning(RESULT_VALUE); in testSubmit() local
99 List<Future<String>> futures = testExecutor.invokeAll(tasks); in testInvokeAll() local
108 List<Future<String>> futures = testExecutor.invokeAll(tasks, timeout, unit); in testInvokeAll() local
134 private static void checkResults(List<Future<String>> futures) in checkResults()
272 public <T> Future<T> submit(Callable<T> task) { in submit()
279 public Future<?> submit(Runnable task) { in submit()
286 public <T> Future<T> submit(Runnable task, T result) { in submit()
|
| D | MoreExecutorsTest.java | 159 List<Future<Integer>> futures = executor.invokeAll(Collections.nCopies(10, incrementTask)); in testDirectExecutorServiceInvokeAll() local
346 Runnable task = in testListeningDecorator_noWrapExecuteTask() local
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | CombinedFuture.java | 36 @CheckForNull private CombinedFutureInterruptibleTask<?> task; field in CombinedFuture
39 ImmutableCollection<? extends ListenableFuture<?>> futures, in CombinedFuture()
49 ImmutableCollection<? extends ListenableFuture<?>> futures, in CombinedFuture()
|
| D | ClosingFuture.java | 463 public static Combiner whenAllComplete(Iterable<? extends ClosingFuture<?>> futures) { in whenAllComplete()
485 public static Combiner whenAllSucceed(Iterable<? extends ClosingFuture<?>> futures) { in whenAllSucceed()
599 TrustedListenableFutureTask<V> task = in ClosingFuture() local
619 TrustedListenableFutureTask<V> task = in ClosingFuture() local
|
| D | MoreExecutors.java | 653 TrustedListenableFutureTask<@Nullable Void> task = in schedule() local
662 TrustedListenableFutureTask<V> task = TrustedListenableFutureTask.create(callable); in schedule() local
670 NeverSuccessfulListenableFutureTask task = new NeverSuccessfulListenableFutureTask(command); in scheduleAtFixedRate() local
678 NeverSuccessfulListenableFutureTask task = new NeverSuccessfulListenableFutureTask(command); in scheduleWithFixedDelay() local
789 List<Future<T>> futures = Lists.newArrayListWithCapacity(ntasks); in invokeAnyImpl() local
860 Callable<T> task, in submitAndAddQueueListener()
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | CombinedFuture.java | 36 @CheckForNull private CombinedFutureInterruptibleTask<?> task; field in CombinedFuture
39 ImmutableCollection<? extends ListenableFuture<?>> futures, in CombinedFuture()
49 ImmutableCollection<? extends ListenableFuture<?>> futures, in CombinedFuture()
|
| D | ClosingFuture.java | 461 public static Combiner whenAllComplete(Iterable<? extends ClosingFuture<?>> futures) { in whenAllComplete()
483 public static Combiner whenAllSucceed(Iterable<? extends ClosingFuture<?>> futures) { in whenAllSucceed()
597 TrustedListenableFutureTask<V> task = in ClosingFuture() local
617 TrustedListenableFutureTask<V> task = in ClosingFuture() local
|
| D | MoreExecutors.java | 592 TrustedListenableFutureTask<@Nullable Void> task = in schedule() local
601 TrustedListenableFutureTask<V> task = TrustedListenableFutureTask.create(callable); in schedule() local
609 NeverSuccessfulListenableFutureTask task = new NeverSuccessfulListenableFutureTask(command); in scheduleAtFixedRate() local
617 NeverSuccessfulListenableFutureTask task = new NeverSuccessfulListenableFutureTask(command); in scheduleWithFixedDelay() local
712 List<Future<T>> futures = Lists.newArrayListWithCapacity(ntasks); in invokeAnyImpl() local
783 Callable<T> task, in submitAndAddQueueListener()
|
| /external/cronet/components/cronet/android/test/javaperftests/src/org/chromium/net/ |
| D | CronetPerfTestActivity.java | 459 private void postToWorkQueue(Runnable task) { in postToWorkQueue()
469 public void execute(Runnable task) { in execute()
525 List<Future<Boolean>> futures = new ArrayList<>(); in run() local
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_tasks.py | 646 async def task(): function
753 def task(): function
770 async def task(): function
785 async def task(): function
806 async def task(): function
830 async def task(): function
859 async def task(): function
880 async def task(): function
1005 async def task(): function
3387 def wrap_futures(self, *futures):
[all …]
|