Home
last modified time | relevance | path

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

1234

/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()
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()
DSimpleTimeLimiter.java50 private final ExecutorService executor; field in SimpleTimeLimiter
66 public SimpleTimeLimiter(ExecutorService executor) { in SimpleTimeLimiter()
DListenableFuture.java134 void addListener(Runnable listener, Executor executor); in addListener()
DAbstractIdleService.java97 protected Executor executor() { in executor() method in AbstractIdleService
/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
DSerializingExecutorTest.java149 final SerializingExecutor executor = new SerializingExecutor( in testDelegateRejection() local
180 final SerializingExecutor executor = new SerializingExecutor(service); in testTaskThrowsError() local
/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/dagger2/compiler/src/it/producers-functional-tests/src/main/java/producerstest/builder/
DTestComponentWithBuilder.java34 Builder executor(Executor executor); in executor() method
/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/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/deqp/modules/glshared/
DglsShaderExecUtil.hpp99 inline tcu::TestLog& operator<< (tcu::TestLog& log, const ShaderExecutor* executor) { executor->log… in operator <<()
100 inline tcu::TestLog& operator<< (tcu::TestLog& log, const ShaderExecutor& executor) { executor.log(… in operator <<()
/external/libgdx/gdx/src/com/badlogic/gdx/utils/async/
DAsyncExecutor.java33 private final ExecutorService executor; field in AsyncExecutor
/external/jacoco/org.jacoco.agent.rt.test/src/org/jacoco/agent/rt/internal/output/
DExecutorTestBase.java32 protected ExecutorService executor; field in ExecutorTestBase
/external/guava/guava/src/com/google/common/cache/
DRemovalListeners.java45 final RemovalListener<K, V> listener, final Executor executor) { in asynchronous()

1234