| /external/mobile-data-download/java/com/google/android/libraries/mobiledatadownload/tracing/ |
| D | PropagatedFutures.java | 40 Executor executor) { in transformAsync()
46 ListenableFuture<I> input, Function<? super I, ? extends O> function, Executor executor) { in transform()
51 ListenableFuture<V> future, FutureCallback<? super V> callback, Executor executor) { in addCallback()
59 Executor executor) { in catching()
67 Executor executor) { in catchingAsync()
72 Callable<V> callable, Executor executor) { in submit()
76 public static ListenableFuture<@Nullable Void> submit(Runnable runnable, Executor executor) { in submit()
81 AsyncCallable<V> callable, Executor executor) { in submitAsync()
86 AsyncCallable<V> callable, long delay, TimeUnit timeUnit, ScheduledExecutorService executor) { in scheduleAsync()
91 public static <V extends @Nullable Object> PropagatedFutureCombiner<V> whenAllComplete( in whenAllComplete()
[all …]
|
| /external/jimfs/jimfs/src/test/java/com/google/common/jimfs/ |
| D | JimfsFileChannelTest.java | 308 ExecutorService executor = Executors.newSingleThreadExecutor(); in testClose() local
678 ExecutorService executor = Executors.newCachedThreadPool(); in testAsynchronousClose() local
681 List<Future<?>> futures = queueAllBlockingOperations(channel, executor, latch); in testAsynchronousClose() local
712 ExecutorService executor = Executors.newCachedThreadPool(); in testCloseByInterrupt() local
744 List<Future<?>> futures = queueAllBlockingOperations(channel, executor, blockingStartLatch); in testCloseByInterrupt() local
783 final FileChannel channel, ExecutorService executor, final CountDownLatch startLatch) { in queueAllBlockingOperations()
784 List<Future<?>> futures = new ArrayList<>(); in queueAllBlockingOperations() local
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | ClosingFuture.java | 388 ClosingCallable<V> callable, Executor executor) { in submit()
400 AsyncClosingCallable<V> callable, Executor executor) { in submitAsync()
463 public static Combiner whenAllComplete(Iterable<? extends ClosingFuture<?>> futures) { in whenAllComplete()
485 public static Combiner whenAllSucceed(Iterable<? extends ClosingFuture<?>> futures) { in whenAllSucceed()
597 private ClosingFuture(final ClosingCallable<V> callable, Executor executor) { in ClosingFuture()
617 private ClosingFuture(final AsyncClosingCallable<V> callable, Executor executor) { in ClosingFuture()
692 final ClosingFunction<? super V, U> function, Executor executor) { in transform()
786 final AsyncClosingFunction<? super V, U> function, Executor executor) { in transformAsync()
|
| D | MoreExecutors.java | 86 ThreadPoolExecutor executor, Duration terminationTimeout) { in getExitingExecutorService()
108 ThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) { in getExitingExecutorService()
127 public static ExecutorService getExitingExecutorService(ThreadPoolExecutor executor) { in getExitingExecutorService()
147 ScheduledThreadPoolExecutor executor, Duration terminationTimeout) { in getExitingScheduledExecutorService()
169 ScheduledThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) { in getExitingScheduledExecutorService()
190 ScheduledThreadPoolExecutor executor) { in getExitingScheduledExecutorService()
236 ThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) { in getExitingExecutorService()
243 final ExecutorService getExitingExecutorService(ThreadPoolExecutor executor) { in getExitingExecutorService()
248 ScheduledThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) { in getExitingScheduledExecutorService()
256 ScheduledThreadPoolExecutor executor) { in getExitingScheduledExecutorService()
[all …]
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | ClosingFuture.java | 385 ClosingCallable<V> callable, Executor executor) { in submit()
397 AsyncClosingCallable<V> callable, Executor executor) { in submitAsync()
461 public static Combiner whenAllComplete(Iterable<? extends ClosingFuture<?>> futures) { in whenAllComplete()
483 public static Combiner whenAllSucceed(Iterable<? extends ClosingFuture<?>> futures) { in whenAllSucceed()
595 private ClosingFuture(final ClosingCallable<V> callable, Executor executor) { in ClosingFuture()
615 private ClosingFuture(final AsyncClosingCallable<V> callable, Executor executor) { in ClosingFuture()
690 final ClosingFunction<? super V, U> function, Executor executor) { in transform()
784 final AsyncClosingFunction<? super V, U> function, Executor executor) { in transformAsync()
|
| D | MoreExecutors.java | 85 ThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) { in getExitingExecutorService()
104 public static ExecutorService getExitingExecutorService(ThreadPoolExecutor executor) { in getExitingExecutorService()
125 ScheduledThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) { in getExitingScheduledExecutorService()
146 ScheduledThreadPoolExecutor executor) { in getExitingScheduledExecutorService()
175 ThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) { in getExitingExecutorService()
182 final ExecutorService getExitingExecutorService(ThreadPoolExecutor executor) { in getExitingExecutorService()
187 ScheduledThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) { in getExitingScheduledExecutorService()
195 ScheduledThreadPoolExecutor executor) { in getExitingScheduledExecutorService()
231 private static void useDaemonThreadFactory(ThreadPoolExecutor executor) { in useDaemonThreadFactory()
712 List<Future<T>> futures = Lists.newArrayListWithCapacity(ntasks); in invokeAnyImpl() local
[all …]
|
| /external/caliper/caliper/src/main/java/com/google/caliper/runner/ |
| D | ExperimentingCaliperRun.java | 154 final ListeningExecutorService executor = executorProvider.get(); in run() local
205 final ListeningExecutorService executor) { in scheduleTrials()
283 Iterable<? extends ListenableFuture<? extends T>> futures) { in inCompletionOrder()
|
| /external/jackson-core/src/test/java/com/fasterxml/jackson/core/json/async/ |
| D | AsyncConcurrencyTest.java | 111 final ExecutorService executor = Executors.newFixedThreadPool(numThreads); in _testConcurrentAsyncOnce() local
125 ArrayList<Future<?>> futures = new ArrayList<Future<?>>(); in _testConcurrentAsyncOnce() local
|
| /external/dagger2/javatests/dagger/internal/ |
| D | DoubleCheckTest.java | 78 ExecutorService executor = Executors.newFixedThreadPool(numThreads); in get() local
93 List<Future<Object>> futures = executor.invokeAll(tasks); in get() local
|
| /external/guava/android/guava-tests/test/com/google/common/graph/ |
| D | ValueGraphTest.java | 392 ExecutorService executor = newFixedThreadPool(threadCount); in concurrentIteration() local
394 ImmutableList.Builder<Future<?>> futures = ImmutableList.builder(); in concurrentIteration() local
|
| D | AbstractNetworkTest.java | 796 ExecutorService executor = newFixedThreadPool(threadCount); in concurrentIteration() local
798 ImmutableList.Builder<Future<?>> futures = ImmutableList.builder(); in concurrentIteration() local
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | MoreExecutorsTest.java | 92 final ListeningExecutorService executor = newDirectExecutorService(); in testDirectExecutorServiceServiceInThreadExecution() local
140 final ExecutorService executor = newDirectExecutorService(); in testDirectExecutorServiceInvokeAll() local
159 List<Future<Integer>> futures = executor.invokeAll(Collections.nCopies(10, incrementTask)); in testDirectExecutorServiceInvokeAll() local
171 final ExecutorService executor = newDirectExecutorService(); in testDirectExecutorServiceServiceTermination() local
303 ExecutorService executor = newDirectExecutorService(); in testDirectExecutorService_shutdownNow() local
309 ExecutorService executor = newDirectExecutorService(); in testExecuteAfterShutdown() local
319 ListeningExecutorService executor = newDirectExecutorService(); in testListeningExecutorServiceInvokeAllJavadocCodeCompiles() local
587 ThreadPoolExecutor executor = in testGetExitingExecutorService_executorSetToUseDaemonThreads() local
596 ThreadPoolExecutor executor = mock(ThreadPoolExecutor.class); in testGetExitingExecutorService_executorDelegatesToOriginal() local
606 ThreadPoolExecutor executor = mock(ThreadPoolExecutor.class); in testGetExitingExecutorService_shutdownHookRegistered() local
[all …]
|
| /external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| D | MoreExecutorsTest.java | 92 final ListeningExecutorService executor = newDirectExecutorService(); in testDirectExecutorServiceServiceInThreadExecution() local
140 final ExecutorService executor = newDirectExecutorService(); in testDirectExecutorServiceInvokeAll() local
159 List<Future<Integer>> futures = executor.invokeAll(Collections.nCopies(10, incrementTask)); in testDirectExecutorServiceInvokeAll() local
171 final ExecutorService executor = newDirectExecutorService(); in testDirectExecutorServiceServiceTermination() local
303 ExecutorService executor = newDirectExecutorService(); in testDirectExecutorService_shutdownNow() local
309 ExecutorService executor = newDirectExecutorService(); in testExecuteAfterShutdown() local
319 ListeningExecutorService executor = newDirectExecutorService(); in testListeningExecutorServiceInvokeAllJavadocCodeCompiles() local
587 ThreadPoolExecutor executor = in testGetExitingExecutorService_executorSetToUseDaemonThreads() local
596 ThreadPoolExecutor executor = mock(ThreadPoolExecutor.class); in testGetExitingExecutorService_executorDelegatesToOriginal() local
606 ThreadPoolExecutor executor = mock(ThreadPoolExecutor.class); in testGetExitingExecutorService_shutdownHookRegistered() local
[all …]
|
| /external/guava/guava-tests/test/com/google/common/graph/ |
| D | ValueGraphTest.java | 452 ExecutorService executor = newFixedThreadPool(threadCount); in concurrentIteration() local
454 ImmutableList.Builder<Future<?>> futures = ImmutableList.builder(); in concurrentIteration() local
|
| D | AbstractNetworkTest.java | 803 ExecutorService executor = newFixedThreadPool(threadCount); in concurrentIteration() local
805 ImmutableList.Builder<Future<?>> futures = ImmutableList.builder(); in concurrentIteration() local
|
| /external/guava/guava-tests/test/com/google/common/eventbus/ |
| D | EventBusTest.java | 245 List<Future<?>> futures = Lists.newArrayList(); in testRegisterThreadSafety() local
246 ExecutorService executor = Executors.newFixedThreadPool(10); in testRegisterThreadSafety() local
|
| /external/guava/android/guava-tests/test/com/google/common/eventbus/ |
| D | EventBusTest.java | 245 List<Future<?>> futures = Lists.newArrayList(); in testRegisterThreadSafety() local
246 ExecutorService executor = Executors.newFixedThreadPool(10); in testRegisterThreadSafety() local
|
| /external/cronet/components/cronet/android/test/javaperftests/src/org/chromium/net/ |
| D | CronetPerfTestActivity.java | 501 final ExecutorService executor = Executors.newFixedThreadPool(mConcurrency); in run() local
525 List<Future<Boolean>> futures = new ArrayList<>(); in run() local
|
| /external/exoplayer/tree_15dc86382f17a24a3e881e52e31a810c1ea44b49/extensions/media2/src/androidTest/java/com/google/android/exoplayer2/ext/media2/ |
| D | SessionPlayerConnectorTest.java | 80 private Executor executor; field in SessionPlayerConnectorTest
427 List<ListenableFuture<PlayerResult>> futures = new ArrayList<>(); in seekTo_whenUnderlyingPlayerAlsoSeeks_throwsNoException() local
|
| /external/exoplayer/tree_8e57d3715f9092d5ec54ebe2e538f34bfcc34479/extensions/media2/src/androidTest/java/com/google/android/exoplayer2/ext/media2/ |
| D | SessionPlayerConnectorTest.java | 80 private Executor executor; field in SessionPlayerConnectorTest
427 List<ListenableFuture<PlayerResult>> futures = new ArrayList<>(); in seekTo_whenUnderlyingPlayerAlsoSeeks_throwsNoException() local
|