Home
last modified time | relevance | path

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

123

/external/guava/guava-tests/test/com/google/common/util/concurrent/
DAbstractExecutionThreadServiceTest.java43 private final Executor executor = new Executor() { field in AbstractExecutionThreadServiceTest
163 @Override protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.WaitOnRunService
198 @Override protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.ThrowOnStartUpService
241 @Override protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.ThrowOnRunService
273 @Override protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.ThrowOnShutDown
290 @Override protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.TimeoutOnStartUp
DMoreExecutorsTest.java49 final ListeningExecutorService executor = in testSameThreadExecutorServiceInThreadExecution() local
96 final ExecutorService executor = MoreExecutors.sameThreadExecutor(); in testSameThreadExecutorInvokeAll() local
127 final ExecutorService executor = MoreExecutors.sameThreadExecutor(); in testSameThreadExecutorServiceTermination() local
DAbstractIdleServiceTest.java36 private final Executor executor = new Executor() { field in AbstractIdleServiceTest
113 @Override protected Executor executor(Service.State state) { in executor() method in AbstractIdleServiceTest.NullService
DAbstractScheduledServiceTest.java51 final ScheduledExecutorService executor = new ScheduledThreadPoolExecutor(10) { field in AbstractScheduledServiceTest
72 @Override protected ScheduledExecutorService executor() { return executor; } in executor() method in AbstractScheduledServiceTest.NullService
219 protected ScheduledExecutorService executor() { in executor() method in AbstractScheduledServiceTest.TestService
367 @Override protected ScheduledExecutorService executor() { in executor() method in AbstractScheduledServiceTest.SchedulerTest.TestAbstractScheduledCustomService
413 @Override protected ScheduledExecutorService executor() { in executor() method in TestFailingCustomScheduledService
/external/guava/guava/src/com/google/common/eventbus/
DAsyncEventBus.java32 private final Executor executor; field in AsyncEventBus
47 public AsyncEventBus(String identifier, Executor executor) { in AsyncEventBus()
60 public AsyncEventBus(Executor executor) { in AsyncEventBus()
/external/guava/guava/src/com/google/common/util/concurrent/
DExecutionList.java80 public void add(Runnable runnable, Executor executor) { in add()
140 final Executor executor; field in ExecutionList.RunnableExecutorPair
142 RunnableExecutorPair(Runnable runnable, Executor executor) { in RunnableExecutorPair()
DMoreExecutors.java69 ThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) { in getExitingExecutorService()
100 ScheduledThreadPoolExecutor executor, long terminationTimeout, in getExitingScheduledExecutorService()
165 ThreadPoolExecutor executor) { in getExitingExecutorService()
186 ScheduledThreadPoolExecutor executor) { in getExitingScheduledExecutorService()
DListenableFuture.java122 void addListener(Runnable listener, Executor executor); in addListener()
DSimpleTimeLimiter.java50 private final ExecutorService executor; field in SimpleTimeLimiter
66 public SimpleTimeLimiter(ExecutorService executor) { in SimpleTimeLimiter()
DAbstractIdleService.java86 protected Executor executor(final State state) { in executor() method in AbstractIdleService
DAbstractExecutionThreadService.java122 protected Executor executor() { in executor() method in AbstractExecutionThreadService
/external/chromium_org/net/proxy/
Dmulti_threaded_proxy_resolver.cc96 void set_executor(Executor* executor) { in set_executor()
103 Executor* executor() { in executor() function in net::MultiThreadedProxyResolver::Job
389 Executor* executor = FindIdleExecutor(); in GetProxyForURL() local
470 Executor* executor = AddNewExecutor(); in SetPacScript() local
481 const Executor* executor = it->get(); in CheckNoOutstandingUserRequests() local
497 Executor* executor = it->get(); in ReleaseAllExecutors() local
508 Executor* executor = it->get(); in FindIdleExecutor() local
522 Executor* executor = new Executor( in AddNewExecutor() local
528 void MultiThreadedProxyResolver::OnExecutorReady(Executor* executor) { in OnExecutorReady()
/external/deqp/executor/
DxeBatchExecutor.cpp346 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
DCMakeLists.txt55 add_executable(executor tools/xeCommandLineExecutor.cpp) target
/external/chromium_org/third_party/WebKit/Source/devtools/scripts/jsdoc-validator/src/org/chromium/devtools/jsdoc/
DJsDocValidator.java22 ExecutorService executor = Executors.newFixedThreadPool(threadCount); in run() local
30 private void runWithExecutor(String[] args, ExecutorService executor) { in runWithExecutor()
/external/chromium_org/components/cronet/android/java/src/org/chromium/net/
DUrlRequestFactory.java25 UrlRequestListener listener, Executor executor); in createRequest()
DCronetUrlRequestFactory.java15 Executor executor) { in createRequest()
/external/chromium_org/chrome/browser/chromeos/drive/
Dfile_task_executor_unittest.cc99 FileTaskExecutor* const executor = new FileTaskExecutor( in TEST() local
133 FileTaskExecutor* const executor = new FileTaskExecutor( in TEST() local
/external/guava/guava/src/com/google/common/cache/
DRemovalListeners.java43 final RemovalListener<K, V> listener, final Executor executor) { in asynchronous()
/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/chromium_org/components/devtools_bridge/test/android/javatests/src/org/chromium/components/devtools_bridge/
DTestUtils.java27 final ExecutorService executor = Executors.newSingleThreadExecutor(); in asyncRequest() local
/external/okhttp/benchmarks/src/main/java/com/squareup/okhttp/benchmarks/
DSynchronousHttpClient.java27 ThreadPoolExecutor executor; field in SynchronousHttpClient
/external/guava/guava-tests/test/com/google/common/eventbus/
DAsyncEventBusTest.java33 private FakeExecutor executor; field in AsyncEventBusTest
/external/smack/src/org/jivesoftware/smackx/bytestreams/socks5/
DSocks5Client.java96 Thread executor = new Thread(futureTask); in getSocket() local
/external/deqp/framework/randomshaders/
DrsgTest.cpp68 rsg::ProgramExecutor executor(surface.getAccess(), 3, 5); in runTest() local

123