| /external/guava/guava/src/com/google/common/eventbus/ |
| D | AsyncEventBus.java | 35 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/ |
| D | ExecutionList.java | 81 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()
|
| D | MoreExecutors.java | 85 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()
774 static Executor renamingDecorator(final Executor executor, final Supplier<String> nameSupplier) { in renamingDecorator()
|
| D | SerializingExecutor.java | 51 private final Executor executor; field in SerializingExecutor
76 public SerializingExecutor(Executor executor) { in SerializingExecutor()
|
| D | ListenerCallQueue.java | 60 private final Executor executor; field in ListenerCallQueue
65 ListenerCallQueue(L listener, Executor executor) { in ListenerCallQueue()
|
| D | Futures.java | 100 public void addListener(Runnable listener, Executor executor) { in addListener()
440 FutureFallback<? extends V> fallback, Executor executor) { in withFallback()
455 final Executor executor) { in FallbackFuture()
607 Executor executor) { in transform()
710 final Function<? super I, ? extends O> function, Executor executor) { in transform()
|
| D | SimpleTimeLimiter.java | 50 private final ExecutorService executor; field in SimpleTimeLimiter
66 public SimpleTimeLimiter(ExecutorService executor) { in SimpleTimeLimiter()
|
| D | ListenableFuture.java | 134 void addListener(Runnable listener, Executor executor); in addListener()
|
| D | AbstractIdleService.java | 97 protected Executor executor() { in executor() method in AbstractIdleService
|
| D | AbstractExecutionThreadService.java | 142 protected Executor executor() { in executor() method in AbstractExecutionThreadService
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | AbstractExecutionThreadServiceTest.java | 158 @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
|
| D | MoreExecutorsTest.java | 90 final ListeningExecutorService executor = in testSameThreadExecutorServiceInThreadExecution() local
137 final ExecutorService executor = MoreExecutors.sameThreadExecutor(); in testSameThreadExecutorInvokeAll() local
168 final ExecutorService executor = MoreExecutors.sameThreadExecutor(); in testSameThreadExecutorServiceTermination() local
247 ExecutorService executor = MoreExecutors.sameThreadExecutor(); in testSameThreadExecutor_shutdownNow() local
253 ExecutorService executor = MoreExecutors.sameThreadExecutor(); in testExecuteAfterShutdown() local
263 ListeningExecutorService executor = MoreExecutors.sameThreadExecutor(); 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 …]
|
| D | AbstractScheduledServiceTest.java | 51 final ScheduledExecutorService executor = new ScheduledThreadPoolExecutor(10) { field in AbstractScheduledServiceTest
70 @Override protected ScheduledExecutorService executor() { return executor; } in executor() method in AbstractScheduledServiceTest.NullService
285 protected ScheduledExecutorService executor() { in executor() method in AbstractScheduledServiceTest.TestService
433 @Override protected ScheduledExecutorService executor() { in executor() method in AbstractScheduledServiceTest.SchedulerTest.TestAbstractScheduledCustomService
479 @Override protected ScheduledExecutorService executor() { in executor() method in TestFailingCustomScheduledService
|
| D | SerializingExecutorTest.java | 148 final SerializingExecutor executor = new SerializingExecutor( in testDelegateRejection() local
179 final SerializingExecutor executor = new SerializingExecutor(service); in testTaskThrowsError() local
|
| /external/guava/guava-tests/benchmark/com/google/common/util/concurrent/ |
| D | ExecutionListBenchmark.java | 55 void add(Runnable runnable, Executor executor); in add()
66 @Override public void add(Runnable runnable, Executor executor) { in newExecutionList()
84 @Override public void add(Runnable runnable, Executor executor) { in newExecutionList()
102 @Override public void add(Runnable runnable, Executor executor) { in newExecutionList()
|
| /external/guava/guava-testlib/test/com/google/common/util/concurrent/testing/ |
| D | TestingExecutorsTest.java | 56 ListeningScheduledExecutorService executor = TestingExecutors.noOpScheduledExecutor(); in testNoOpScheduledExecutorShutdown() local
65 ListeningScheduledExecutorService executor = TestingExecutors.noOpScheduledExecutor(); in testNoOpScheduledExecutorInvokeAll() local
|
| /external/deqp/executor/ |
| D | xeBatchExecutor.cpp | 346 BatchExecutor* executor = static_cast<BatchExecutor*>(userPtr); in enqueueStateChanged() local
358 BatchExecutor* executor = static_cast<BatchExecutor*>(userPtr); in enqueueTestLogData() local
370 BatchExecutor* executor = static_cast<BatchExecutor*>(userPtr); in enqueueInfoLogData() local
382 BatchExecutor* executor = DE_NULL; in dispatchStateChanged() local
395 BatchExecutor* executor = DE_NULL; in dispatchTestLogData() local
406 BatchExecutor* executor = DE_NULL; in dispatchInfoLogData() local
|
| D | CMakeLists.txt | 55 add_executable(executor tools/xeCommandLineExecutor.cpp) target
|
| /external/deqp/modules/glshared/ |
| D | glsShaderExecUtil.hpp | 99 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/guava/guava/src/com/google/common/cache/ |
| D | RemovalListeners.java | 45 final RemovalListener<K, V> listener, final Executor executor) { in asynchronous()
|
| /external/jetty/src/java/org/eclipse/jetty/util/thread/ |
| D | ExecutorThreadPool.java | 47 public ExecutorThreadPool(ExecutorService executor) in ExecutorThreadPool()
|
| /external/vogar/src/vogar/target/ |
| D | TestActivity.java | 47 ExecutorService executor = Threads.fixedThreadsExecutor(log, "testactivity", 1); in onCreate() local
|
| /external/okhttp/samples/guide/src/main/java/com/squareup/okhttp/recipes/ |
| D | CancelCall.java | 28 private final ScheduledExecutorService executor = Executors.newScheduledThreadPool(1); field in CancelCall
|
| /external/okhttp/benchmarks/src/main/java/com/squareup/okhttp/benchmarks/ |
| D | SynchronousHttpClient.java | 27 ThreadPoolExecutor executor; field in SynchronousHttpClient
|
| /external/guava/guava-tests/test/com/google/common/cache/ |
| D | CacheLoaderTest.java | 88 QueuingExecutor executor = new QueuingExecutor(); in testAsyncReload() local
|