Home
last modified time | relevance | path

Searched defs:executor (Results 1 – 25 of 113) sorted by relevance

12345

/external/guava/guava-tests/benchmark/com/google/common/util/concurrent/
DMoreExecutorsDirectExecutorBenchmark.java42 @Override Executor executor() { in executor() method
47 @Override Executor executor() { in executor() method
51 abstract Executor executor(); in executor() method in MoreExecutorsDirectExecutorBenchmark.Impl
55 Executor executor; field in MoreExecutorsDirectExecutorBenchmark
96 final Executor executor = this.executor; in timeUncontendedExecute() local
105 final Executor executor = this.executor; in timeContendedExecute() local
DExecutionListBenchmark.java53 void add(Runnable runnable, Executor executor); in add()
64 @Override public void add(Runnable runnable, Executor executor) { in newExecutionList()
82 @Override public void add(Runnable runnable, Executor executor) { in newExecutionList()
100 @Override public void add(Runnable runnable, Executor executor) { in newExecutionList()
DFuturesCombineBenchmark.java39 @Override <V> ListenableFuture<V> combine(final Callable<V> combiner, Executor executor, in combine()
54 }, executor); in combine() field in FuturesCombineBenchmark
/external/guava/guava/src/com/google/common/eventbus/
DAsyncEventBus.java35 private final Executor executor; field in AsyncEventBus
50 public AsyncEventBus(String identifier, Executor executor) { in AsyncEventBus()
66 public AsyncEventBus(Executor executor, SubscriberExceptionHandler subscriberExceptionHandler) { in AsyncEventBus()
79 public AsyncEventBus(Executor executor) { in AsyncEventBus()
/external/guava/guava/src/com/google/common/util/concurrent/
DExecutionList.java81 public void add(Runnable runnable, Executor executor) { in add()
154 private static void executeListener(Runnable runnable, Executor executor) { in executeListener()
168 final Executor executor; field in ExecutionList.RunnableExecutorPair
171 RunnableExecutorPair(Runnable runnable, Executor executor, RunnableExecutorPair next) { in RunnableExecutorPair()
DMoreExecutors.java85 ThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) { in getExitingExecutorService()
108 ScheduledThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) { in getExitingScheduledExecutorService()
147 public static ExecutorService getExitingExecutorService(ThreadPoolExecutor executor) { in getExitingExecutorService()
168 ScheduledThreadPoolExecutor executor) { in getExitingScheduledExecutorService()
176 ThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) { in getExitingExecutorService()
184 ScheduledThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) { in getExitingScheduledExecutorService()
213 final ExecutorService getExitingExecutorService(ThreadPoolExecutor executor) { in getExitingExecutorService()
218 ScheduledThreadPoolExecutor executor) { in getExitingScheduledExecutorService()
227 private static void useDaemonThreadFactory(ThreadPoolExecutor executor) { in useDaemonThreadFactory()
840 static Executor renamingDecorator(final Executor executor, final Supplier<String> nameSupplier) { in renamingDecorator()
DSerializingExecutor.java51 private final Executor executor; field in SerializingExecutor
76 public SerializingExecutor(Executor executor) { in SerializingExecutor()
DListenerCallQueue.java60 private final Executor executor; field in ListenerCallQueue
65 ListenerCallQueue(L listener, Executor executor) { in ListenerCallQueue()
DListenableFuture.java134 void addListener(Runnable listener, Executor executor); in addListener()
DSimpleTimeLimiter.java50 private final ExecutorService executor; field in SimpleTimeLimiter
66 public SimpleTimeLimiter(ExecutorService executor) { in SimpleTimeLimiter()
DFutures.java102 public void addListener(Runnable listener, Executor executor) { in addListener()
442 FutureFallback<? extends V> fallback, Executor executor) { in withFallback()
457 final Executor executor) { in FallbackFuture()
612 Executor executor) { in transform()
/external/r8/src/test/java/com/android/tools/r8/
DR8EntryPointTests.java61 ExecutorService executor = Executors.newWorkStealingPool(2); in testRun2Dir() local
63 R8.run(getCommand(out), executor); in testRun2Dir() local
75 ExecutorService executor = Executors.newWorkStealingPool(2); in testRun2Zip() local
77 R8.run(getCommand(out), executor); in testRun2Zip() local
/external/guava/guava-tests/test/com/google/common/util/concurrent/
DAbstractExecutionThreadServiceTest.java158 @Override protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.WaitOnRunService
193 @Override protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.ThrowOnStartUpService
247 @Override protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.ThrowOnRunService
279 @Override protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.ThrowOnShutDown
296 @Override protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.TimeoutOnStartUp
344 private final ExecutorService executor = Executors.newSingleThreadExecutor(); field in AbstractExecutionThreadServiceTest.FakeService
375 @Override protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.FakeService
DMoreExecutorsTest.java91 final ListeningExecutorService executor = newDirectExecutorService(); in testDirectExecutorServiceServiceInThreadExecution() local
137 final ExecutorService executor = newDirectExecutorService(); in testDirectExecutorServiceInvokeAll() local
168 final ExecutorService executor = newDirectExecutorService(); in testDirectExecutorServiceServiceTermination() local
247 ExecutorService executor = newDirectExecutorService(); in testDirectExecutorService_shutdownNow() local
253 ExecutorService executor = newDirectExecutorService(); in testExecuteAfterShutdown() local
263 ListeningExecutorService executor = newDirectExecutorService(); in testListeningExecutorServiceInvokeAllJavadocCodeCompiles() local
534 ThreadPoolExecutor executor = new ThreadPoolExecutor( in testGetExitingExcutorService_executorSetToUseDaemonThreads() local
542 ThreadPoolExecutor executor = mock(ThreadPoolExecutor.class); in testGetExitingExcutorService_executorDelegatesToOriginal() local
551 ThreadPoolExecutor executor = mock(ThreadPoolExecutor.class); in testGetExitingExcutorService_shutdownHookRegistered() local
561 ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(1); in testGetExitingScheduledExcutorService_executorSetToUseDaemonThreads() local
[all …]
DAbstractScheduledServiceTest.java51 final ScheduledExecutorService executor = new ScheduledThreadPoolExecutor(10) { field in AbstractScheduledServiceTest
70 @Override protected ScheduledExecutorService executor() { return executor; } in executor() method in AbstractScheduledServiceTest.NullService
152 final AtomicReference<ScheduledExecutorService> executor = Atomics.newReference(); in testDefaultExecutorIsShutdownWhenServiceIsStopped() local
175 final AtomicReference<ScheduledExecutorService> executor = Atomics.newReference(); in testDefaultExecutorIsShutdownWhenServiceFails() local
267 protected ScheduledExecutorService executor() { in executor() method in AbstractScheduledServiceTest.TestService
415 @Override protected ScheduledExecutorService executor() { in executor() method in AbstractScheduledServiceTest.SchedulerTest.TestAbstractScheduledCustomService
461 @Override protected ScheduledExecutorService executor() { in executor() method in TestFailingCustomScheduledService
/external/guice/extensions/service/src/com/google/inject/service/
DAsyncService.java37 private final ExecutorService executor; field in AsyncService
41 public AsyncService(ExecutorService executor) { in AsyncService()
/external/r8/src/main/java/com/android/tools/r8/
DD8.java83 public static D8Output run(D8Command command, ExecutorService executor) throws IOException { in run()
143 ExecutorService executor = ThreadUtils.getExecutorService(options); in runForTesting() local
152 AndroidApp inputApp, InternalOptions options, ExecutorService executor) throws IOException { in runForTesting()
194 Timing timing, ExecutorService executor) in optimize()
DIncrementalDexingBenchmark.java14 public static void compile(ExecutorService executor) throws IOException, CompilationException { in compile()
29 ExecutorService executor = ThreadUtils.getExecutorService(threads); in main() local
/external/dagger2/compiler/src/it/producers-functional-tests/src/main/java/producerstest/builder/
DTestComponentWithBuilder.java34 Builder executor(Executor executor); in executor() argument
/external/guice/extensions/service/test/com/google/inject/service/
DSingleServiceIntegrationTest.java22 ExecutorService executor = Executors.newSingleThreadExecutor(); in testAsyncServiceLifecycle() local
61 ExecutorService executor = Executors.newSingleThreadExecutor(); in testAsyncServiceBlockingLifecycle() local
/external/r8/src/main/java/com/android/tools/r8/bisect/
DBisect.java71 ExecutorService executor) in run()
103 ExecutorService executor = Executors.newWorkStealingPool(); in run() local
172 private DexApplication readApp(File apk, ExecutorService executor) in readApp()
178 private static void writeApp(DexApplication app, Path output, ExecutorService executor) in writeApp()
/external/guava/guava-testlib/test/com/google/common/util/concurrent/testing/
DTestingExecutorsTest.java56 ListeningScheduledExecutorService executor = TestingExecutors.noOpScheduledExecutor(); in testNoOpScheduledExecutorShutdown() local
65 ListeningScheduledExecutorService executor = TestingExecutors.noOpScheduledExecutor(); in testNoOpScheduledExecutorInvokeAll() local
/external/deqp/executor/
DxeBatchExecutor.cpp352 BatchExecutor* executor = static_cast<BatchExecutor*>(userPtr); in enqueueStateChanged() local
364 BatchExecutor* executor = static_cast<BatchExecutor*>(userPtr); in enqueueTestLogData() local
376 BatchExecutor* executor = static_cast<BatchExecutor*>(userPtr); in enqueueInfoLogData() local
388 BatchExecutor* executor = DE_NULL; in dispatchStateChanged() local
401 BatchExecutor* executor = DE_NULL; in dispatchTestLogData() local
412 BatchExecutor* executor = DE_NULL; in dispatchInfoLogData() local
/external/guava/guava/src/com/google/common/cache/
DRemovalListeners.java45 final RemovalListener<K, V> listener, final Executor executor) { in asynchronous()
/external/jacoco/org.jacoco.agent.rt.test/src/org/jacoco/agent/rt/internal/output/
DExecutorTestBase.java32 protected ExecutorService executor; field in ExecutorTestBase

12345