| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | MoreExecutorsTest.java | 49 final ListeningExecutorService executor = in testSameThreadExecutorServiceInThreadExecution() local
72 Future<?> future = executor.submit(incrementTask); in testSameThreadExecutorServiceInThreadExecution()
83 ListenableFuture<?> future = executor.submit(incrementTask); in testSameThreadExecutorServiceInThreadExecution()
96 final ExecutorService executor = MoreExecutors.sameThreadExecutor(); in testSameThreadExecutorInvokeAll() local
114 executor.invokeAll(Collections.nCopies(10, incrementTask)); in testSameThreadExecutorInvokeAll()
127 final ExecutorService executor = MoreExecutors.sameThreadExecutor(); in testSameThreadExecutorServiceTermination() local
139 Future<?> future = executor.submit(new Callable<Void>() { in testSameThreadExecutorServiceTermination()
147 assertTrue(executor.isShutdown()); in testSameThreadExecutorServiceTermination()
148 assertFalse(executor.isTerminated()); in testSameThreadExecutorServiceTermination()
156 assertTrue(executor.isShutdown()); in testSameThreadExecutorServiceTermination()
[all …]
|
| D | AbstractExecutionThreadServiceTest.java | 43 private final Executor executor = new Executor() { field in AbstractExecutionThreadServiceTest
163 @Override protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.WaitOnRunService
164 return executor; in executor()
198 @Override protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.ThrowOnStartUpService
199 return executor; in executor()
241 @Override protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.ThrowOnRunService
242 return executor; in executor()
273 @Override protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.ThrowOnShutDown
274 return executor; in executor()
290 @Override protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.TimeoutOnStartUp
|
| D | AbstractIdleServiceTest.java | 36 private final Executor executor = new Executor() { field in AbstractIdleServiceTest
78 @Override protected Executor executor(Service.State state) { in testTimeout()
113 @Override protected Executor executor(Service.State state) { in executor() method in AbstractIdleServiceTest.NullService
117 return executor; in executor()
121 return executor; in executor()
|
| D | AbstractFutureTest.java | 94 ExecutorService executor = Executors.newFixedThreadPool(10); in testCompletionFinishesWithDone() local
98 executor.execute(new Runnable() { in testCompletionFinishesWithDone()
107 executor.execute(new Runnable() { in testCompletionFinishesWithDone()
116 executor.execute(new Runnable() { in testCompletionFinishesWithDone()
133 executor.shutdown(); in testCompletionFinishesWithDone()
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | ExecutionList.java | 80 public void add(Runnable runnable, Executor executor) { in add() argument
85 Preconditions.checkNotNull(executor, "Executor was null."); in add()
94 runnables.add(new RunnableExecutorPair(runnable, executor)); in add()
105 new RunnableExecutorPair(runnable, executor).execute(); in add()
140 final Executor executor; field in ExecutionList.RunnableExecutorPair
142 RunnableExecutorPair(Runnable runnable, Executor executor) { in RunnableExecutorPair() argument
144 this.executor = executor; in RunnableExecutorPair()
149 executor.execute(runnable); in execute()
155 + runnable + " with executor " + executor, e); in execute()
|
| D | AbstractScheduledService.java | 120 public Future<?> schedule(AbstractService service, ScheduledExecutorService executor, in newFixedDelaySchedule()
122 return executor.scheduleWithFixedDelay(task, initialDelay, delay, unit); in newFixedDelaySchedule()
139 public Future<?> schedule(AbstractService service, ScheduledExecutorService executor, in newFixedRateSchedule()
141 return executor.scheduleAtFixedRate(task, initialDelay, period, unit); in newFixedRateSchedule()
147 abstract Future<?> schedule(AbstractService service, ScheduledExecutorService executor,
186 executorService = executor();
260 protected ScheduledExecutorService executor() {
314 private final ScheduledExecutorService executor;
333 ReschedulableCallable(AbstractService service, ScheduledExecutorService executor,
336 this.executor = executor;
[all …]
|
| D | MoreExecutors.java | 69 ThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) { in getExitingExecutorService() argument
70 executor.setThreadFactory(new ThreadFactoryBuilder() in getExitingExecutorService()
72 .setThreadFactory(executor.getThreadFactory()) in getExitingExecutorService()
75 ExecutorService service = Executors.unconfigurableExecutorService(executor); in getExitingExecutorService()
100 ScheduledThreadPoolExecutor executor, long terminationTimeout, in getExitingScheduledExecutorService() argument
102 executor.setThreadFactory(new ThreadFactoryBuilder() in getExitingScheduledExecutorService()
104 .setThreadFactory(executor.getThreadFactory()) in getExitingScheduledExecutorService()
108 Executors.unconfigurableScheduledExecutorService(executor); in getExitingScheduledExecutorService()
165 ThreadPoolExecutor executor) { in getExitingExecutorService() argument
166 return getExitingExecutorService(executor, 120, TimeUnit.SECONDS); in getExitingExecutorService()
[all …]
|
| D | SimpleTimeLimiter.java | 50 private final ExecutorService executor; field in SimpleTimeLimiter
66 public SimpleTimeLimiter(ExecutorService executor) { in SimpleTimeLimiter() argument
67 this.executor = checkNotNull(executor); in SimpleTimeLimiter()
126 Future<T> future = executor.submit(callable); in callWithTimeout()
|
| D | AbstractIdleService.java | 40 executor(State.STARTING).execute(new Runnable() {
54 executor(State.STOPPING).execute(new Runnable() {
86 protected Executor executor(final State state) { in executor() method in AbstractIdleService
|
| D | JdkFutureAdapters.java | 68 Future<V> future, Executor executor) { in listenInPoolThread() argument
69 checkNotNull(executor); in listenInPoolThread()
73 return new ListenableFutureAdapter<V>(future, executor); in listenInPoolThread()
|
| /external/chromium_org/net/proxy/ |
| D | multi_threaded_proxy_resolver.cc | 96 void set_executor(Executor* executor) { in set_executor() argument
97 executor_ = executor; in set_executor()
103 Executor* executor() { in executor() function in net::MultiThreadedProxyResolver::Job
179 ProxyResolver* resolver = executor()->resolver(); in Run()
231 DCHECK(executor()); in FinishedWaitingForThread()
239 NetLog::IntegerCallback("thread_number", executor()->thread_number())); in FinishedWaitingForThread()
244 ProxyResolver* resolver = executor()->resolver(); in Run()
389 Executor* executor = FindIdleExecutor(); in GetProxyForURL() local
390 if (executor) { in GetProxyForURL()
392 executor->StartJob(job.get()); in GetProxyForURL()
[all …]
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
| D | DispatcherTest.java | 16 RecordingExecutor executor = new RecordingExecutor(); field in DispatcherTest
18 Dispatcher dispatcher = new Dispatcher(executor);
44 executor.assertJobs("http://a/1"); in enqueuedJobsRunImmediately()
53 executor.assertJobs("http://a/1", "http://a/2", "http://b/1"); in maxRequestsEnforced()
61 executor.assertJobs("http://a/1", "http://a/2"); in maxPerHostEnforced()
72 executor.assertJobs("http://a/1", "http://b/1", "http://c/1", "http://a/2"); in increasingMaxRequestsPromotesJobsImmediately()
83 executor.assertJobs("http://a/1", "http://a/2", "http://a/3", "http://a/4"); in increasingMaxPerHostPromotesJobsImmediately()
90 executor.finishJob("http://a/1"); in oldJobFinishesNewJobCanRunDifferentHost()
91 executor.assertJobs("http://b/1"); in oldJobFinishesNewJobCanRunDifferentHost()
101 executor.finishJob("http://a/1"); in oldJobFinishesNewJobWithSameHostStarts()
[all …]
|
| /external/guava/guava/src/com/google/common/eventbus/ |
| D | AsyncEventBus.java | 32 private final Executor executor; field in AsyncEventBus
47 public AsyncEventBus(String identifier, Executor executor) { in AsyncEventBus() argument
49 this.executor = executor; in AsyncEventBus()
60 public AsyncEventBus(Executor executor) { in AsyncEventBus() argument
61 this.executor = executor; in AsyncEventBus()
90 executor.execute(new Runnable() { in dispatch()
|
| /external/deqp/executor/ |
| D | xeBatchExecutor.cpp | 346 BatchExecutor* executor = static_cast<BatchExecutor*>(userPtr); in enqueueStateChanged() local
347 CallWriter writer (&executor->m_dispatcher, BatchExecutor::dispatchStateChanged); in enqueueStateChanged()
349 writer << executor in enqueueStateChanged()
358 BatchExecutor* executor = static_cast<BatchExecutor*>(userPtr); in enqueueTestLogData() local
359 CallWriter writer (&executor->m_dispatcher, BatchExecutor::dispatchTestLogData); in enqueueTestLogData()
361 writer << executor in enqueueTestLogData()
370 BatchExecutor* executor = static_cast<BatchExecutor*>(userPtr); in enqueueInfoLogData() local
371 CallWriter writer (&executor->m_dispatcher, BatchExecutor::dispatchInfoLogData); in enqueueInfoLogData()
373 writer << executor in enqueueInfoLogData()
382 BatchExecutor* executor = DE_NULL; in dispatchStateChanged() local
[all …]
|
| /external/okhttp/benchmarks/src/main/java/com/squareup/okhttp/benchmarks/ |
| D | SynchronousHttpClient.java | 27 ThreadPoolExecutor executor; field in SynchronousHttpClient
32 executor = new ThreadPoolExecutor(benchmark.concurrencyLevel, benchmark.concurrencyLevel, in prepare()
37 executor.execute(request(url)); in enqueue()
41 return executor.getQueue().size() < targetBacklog; in acceptingJobs()
|
| /external/guava/guava-tests/test/com/google/common/eventbus/ |
| D | AsyncEventBusTest.java | 33 private FakeExecutor executor; field in AsyncEventBusTest
38 executor = new FakeExecutor(); in setUp()
39 bus = new AsyncEventBus(executor); in setUp()
54 List<Runnable> tasks = executor.getTasks(); in testBasicDistribution()
|
| /external/deqp/modules/glshared/ |
| D | glsShaderExecUtil.hpp | 99 inline tcu::TestLog& operator<< (tcu::TestLog& log, const ShaderExecutor* executor) { executor->log… in operator <<() argument
100 inline tcu::TestLog& operator<< (tcu::TestLog& log, const ShaderExecutor& executor) { executor.log(… in operator <<() argument
|
| /external/chromium_org/mojo/public/java/bindings/src/org/chromium/mojo/bindings/ |
| D | ExecutorFactory.java | 177 Executor executor = EXECUTORS.get(); in getExecutorForCurrentThread() local
178 if (executor == null) { in getExecutorForCurrentThread()
179 executor = new PipedExecutor(core); in getExecutorForCurrentThread()
180 EXECUTORS.set(executor); in getExecutorForCurrentThread()
182 return executor; in getExecutorForCurrentThread()
|
| /external/jmdns/src/javax/jmdns/impl/ |
| D | JmmDNSImpl.java | 88 ExecutorService executor = Executors.newCachedThreadPool(); in close() local
90 executor.submit(new Runnable() { in close()
104 executor.shutdown(); in close()
106 executor.awaitTermination(DNSConstants.CLOSE_TIMEOUT, TimeUnit.MILLISECONDS); in close()
201 ExecutorService executor = Executors.newCachedThreadPool(); in getServiceInfos() local
203 executor.submit(new Runnable() { in getServiceInfos()
213 executor.shutdown(); in getServiceInfos()
215 executor.awaitTermination(timeout, TimeUnit.MILLISECONDS); in getServiceInfos()
404 ExecutorService executor = Executors.newCachedThreadPool(); in list() local
406 executor.submit(new Runnable() { in list()
[all …]
|
| /external/chromium_org/third_party/WebKit/Source/devtools/scripts/jsdoc-validator/src/org/chromium/devtools/jsdoc/ |
| D | JsDocValidator.java | 22 ExecutorService executor = Executors.newFixedThreadPool(threadCount); in run() local
24 runWithExecutor(args, executor); in run()
26 executor.shutdown(); in run()
30 private void runWithExecutor(String[] args, ExecutorService executor) { in runWithExecutor() argument
34 Future<ValidatorContext> future = executor.submit(new FileCheckerCallable(fileName)); in runWithExecutor()
|
| /external/owasp/sanitizer/src/tests/org/owasp/html/ |
| D | HtmlSanitizerFuzzerTest.java | 75 ThreadPoolExecutor executor = new ThreadPoolExecutor( in testFuzzHtmlParser() local
128 executor.execute(new Runnable() { in testFuzzHtmlParser()
141 executor.shutdown(); in testFuzzHtmlParser()
142 executor.awaitTermination(runCount * 4, TimeUnit.SECONDS); in testFuzzHtmlParser()
143 assertTrue("seed=" + seed, executor.isTerminated()); in testFuzzHtmlParser()
|
| /external/chromium_org/chrome/browser/chromeos/drive/ |
| D | file_task_executor_unittest.cc | 99 FileTaskExecutor* const executor = new FileTaskExecutor( in TEST() local
114 executor->Execute(urls, in TEST()
133 FileTaskExecutor* const executor = new FileTaskExecutor( in TEST() local
144 executor->Execute(urls, in TEST()
|
| /external/guava/guava/src/com/google/common/cache/ |
| D | RemovalListeners.java | 43 final RemovalListener<K, V> listener, final Executor executor) { in asynchronous() argument
47 executor.execute(new Runnable() { in asynchronous()
|
| /external/chromium_org/third_party/closure_compiler/runner/src/org/chromium/closure/compiler/ |
| D | Runner.java | 101 ExecutorService executor = Executors.newFixedThreadPool( in run() local
104 runWithExecutor(descriptors, executor); in run()
106 executor.shutdown(); in run()
111 List<CompilerInstanceDescriptor> descriptors, ExecutorService executor) { in runWithExecutor() argument
115 futures.add(executor.submit(task)); in runWithExecutor()
|
| /external/chromium_org/third_party/WebKit/Source/devtools/scripts/compiler-runner/src/org/chromium/devtools/compiler/ |
| D | Runner.java | 96 ExecutorService executor = Executors.newFixedThreadPool( in run() local
99 runWithExecutor(descriptors, executor); in run()
101 executor.shutdown(); in run()
106 List<CompilerInstanceDescriptor> descriptors, ExecutorService executor) { in runWithExecutor() argument
110 futures.add(executor.submit(task)); in runWithExecutor()
|