| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | ForwardingExecutorService.java | 53 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll() method in ForwardingExecutorService
55 return delegate().invokeAll(tasks); in invokeAll()
59 public <T> List<Future<T>> invokeAll( in invokeAll() method in ForwardingExecutorService
62 return delegate().invokeAll(tasks, timeout, unit); in invokeAll()
|
| D | WrappingExecutorService.java | 112 public final <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
114 return delegate.invokeAll(wrapTasks(tasks));
118 public final <T> List<Future<T>> invokeAll(
121 return delegate.invokeAll(wrapTasks(tasks), timeout, unit);
|
| D | ListeningExecutorService.java | 80 <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll() method
103 <T> List<Future<T>> invokeAll( in invokeAll() method
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | ForwardingExecutorService.java | 53 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll() method in ForwardingExecutorService
55 return delegate().invokeAll(tasks); in invokeAll()
59 public <T> List<Future<T>> invokeAll( in invokeAll() method in ForwardingExecutorService
62 return delegate().invokeAll(tasks, timeout, unit); in invokeAll()
|
| D | WrappingExecutorService.java | 112 public final <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
114 return delegate.invokeAll(wrapTasks(tasks));
118 public final <T> List<Future<T>> invokeAll(
121 return delegate.invokeAll(wrapTasks(tasks), timeout, unit);
|
| D | ListeningExecutorService.java | 80 <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll() method
103 <T> List<Future<T>> invokeAll( in invokeAll() method
|
| /external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| D | WrappingExecutorServiceTest.java | 99 List<Future<String>> futures = testExecutor.invokeAll(tasks); in testInvokeAll()
108 List<Future<String>> futures = testExecutor.invokeAll(tasks, timeout, unit); in testInvokeAll()
213 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll() method in WrappingExecutorServiceTest.MockExecutor
217 return inline.invokeAll(tasks); in invokeAll()
221 public <T> List<Future<T>> invokeAll( in invokeAll() method in WrappingExecutorServiceTest.MockExecutor
227 return inline.invokeAll(tasks, timeout, unit); in invokeAll()
|
| D | WrappingScheduledExecutorServiceTest.java | 181 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll() method in WrappingScheduledExecutorServiceTest.MockExecutor
187 public <T> List<Future<T>> invokeAll( in invokeAll() method in WrappingScheduledExecutorServiceTest.MockExecutor
|
| D | MoreExecutorsTest.java | 159 List<Future<Integer>> futures = executor.invokeAll(Collections.nCopies(10, incrementTask)); in testDirectExecutorServiceInvokeAll()
322 List<? extends Future<?>> unused = executor.invokeAll(tasks); in testListeningExecutorServiceInvokeAllJavadocCodeCompiles()
331 results = service.invokeAll(callables); in testListeningDecorator()
334 results = service.invokeAll(callables, 1, SECONDS); in testListeningDecorator()
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | WrappingExecutorServiceTest.java | 99 List<Future<String>> futures = testExecutor.invokeAll(tasks); in testInvokeAll()
108 List<Future<String>> futures = testExecutor.invokeAll(tasks, timeout, unit); in testInvokeAll()
213 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll() method in WrappingExecutorServiceTest.MockExecutor
217 return inline.invokeAll(tasks); in invokeAll()
221 public <T> List<Future<T>> invokeAll( in invokeAll() method in WrappingExecutorServiceTest.MockExecutor
227 return inline.invokeAll(tasks, timeout, unit); in invokeAll()
|
| D | WrappingScheduledExecutorServiceTest.java | 181 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll() method in WrappingScheduledExecutorServiceTest.MockExecutor
187 public <T> List<Future<T>> invokeAll( in invokeAll() method in WrappingScheduledExecutorServiceTest.MockExecutor
|
| D | MoreExecutorsTest.java | 159 List<Future<Integer>> futures = executor.invokeAll(Collections.nCopies(10, incrementTask)); in testDirectExecutorServiceInvokeAll()
322 List<? extends Future<?>> unused = executor.invokeAll(tasks); in testListeningExecutorServiceInvokeAllJavadocCodeCompiles()
331 results = service.invokeAll(callables); in testListeningDecorator()
334 results = service.invokeAll(callables, 1, SECONDS); in testListeningDecorator()
|
| /external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/ |
| D | SameThreadScheduledExecutorService.java | 98 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll() method in SameThreadScheduledExecutorService
101 return delegate.invokeAll(tasks); in invokeAll()
105 public <T> List<Future<T>> invokeAll( in invokeAll() method in SameThreadScheduledExecutorService
110 return delegate.invokeAll(tasks, timeout, unit); in invokeAll()
|
| /external/guava/android/guava-testlib/src/com/google/common/util/concurrent/testing/ |
| D | SameThreadScheduledExecutorService.java | 98 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll() method in SameThreadScheduledExecutorService
101 return delegate.invokeAll(tasks); in invokeAll()
105 public <T> List<Future<T>> invokeAll( in invokeAll() method in SameThreadScheduledExecutorService
110 return delegate.invokeAll(tasks, timeout, unit); in invokeAll()
|
| /external/exoplayer/tree/library/core/src/main/java/com/google/android/exoplayer2/ |
| D | ExoPlayerImpl.java | 1220 notifyListeners(() -> invokeAll(listenerSnapshot, listenerInvocation)); in notifyListeners()
1301 invokeAll( in run()
1306 invokeAll( in run()
1311 invokeAll(listenerSnapshot, listener -> listener.onPlayerError(playbackInfo.playbackError)); in run()
1315 invokeAll( in run()
1322 invokeAll( in run()
1326 invokeAll( in run()
1333 invokeAll( in run()
1338 invokeAll( in run()
1345 invokeAll( in run()
[all …]
|
| /external/testng/src/main/java/org/testng/internal/thread/ |
| D | ThreadUtil.java | 72 pooledExecutor.invokeAll(callables, timeout, TimeUnit.MILLISECONDS); in execute()
74 pooledExecutor.invokeAll(callables); in execute()
|
| /external/robolectric-shadows/shadows/framework/src/main/java/org/robolectric/android/util/concurrent/ |
| D | RoboExecutorService.java | 114 …public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> callables) throws Interrupt… in invokeAll() method in RoboExecutorService
119 …public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> callables, long l, TimeUnit… in invokeAll() method in RoboExecutorService
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | FakeClock.java | 137 @Override public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) { in invokeAll() method in FakeClock.ScheduledExecutorImpl
141 @Override public <T> List<Future<T>> invokeAll( in invokeAll() method in FakeClock.ScheduledExecutorImpl
|
| /external/guava/android/guava-testlib/test/com/google/common/util/concurrent/testing/ |
| D | TestingExecutorsTest.java | 75 executor.invokeAll(ImmutableList.of(task), 10, TimeUnit.MILLISECONDS); in testNoOpScheduledExecutorInvokeAll()
|
| /external/guava/guava-testlib/test/com/google/common/util/concurrent/testing/ |
| D | TestingExecutorsTest.java | 75 executor.invokeAll(ImmutableList.of(task), 10, TimeUnit.MILLISECONDS); in testNoOpScheduledExecutorInvokeAll()
|
| /external/dagger2/java/dagger/internal/codegen/writing/ |
| D | MembersInjectionMethods.java | 109 InjectionSiteMethod.invokeAll( in membersInjectionMethod()
|
| D | MembersInjectorGenerator.java | 203 InjectionSiteMethod.invokeAll( in write()
|
| D | FactoryGenerator.java | 266 InjectionSiteMethod.invokeAll( in getMethod()
|
| /external/dagger2/javatests/dagger/internal/ |
| D | DoubleCheckTest.java | 93 List<Future<Object>> futures = executor.invokeAll(tasks); in get()
|
| /external/grpc-grpc-java/android/src/test/java/io/grpc/android/ |
| D | AndroidChannelBuilderTest.java | 444 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) { in invokeAll() method in AndroidChannelBuilderTest.ScheduledExecutorImpl
449 public <T> List<Future<T>> invokeAll( in invokeAll() method in AndroidChannelBuilderTest.ScheduledExecutorImpl
|