| /external/guava/guava-tests/benchmark/com/google/common/util/concurrent/ |
| D | ExecutionListBenchmark.java | 55 void add(Runnable runnable, Executor executor); in add() argument
66 @Override public void add(Runnable runnable, Executor executor) { in newExecutionList() argument
67 list.add(runnable, executor); in newExecutionList()
84 @Override public void add(Runnable runnable, Executor executor) { in newExecutionList() argument
85 list.add(runnable, executor); in newExecutionList()
102 @Override public void add(Runnable runnable, Executor executor) { in newExecutionList() argument
103 list.add(runnable, executor); in newExecutionList()
120 @Override public void add(Runnable runnable, Executor executor) {
121 list.add(runnable, executor);
138 @Override public void add(Runnable runnable, Executor executor) {
[all …]
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | MoreExecutorsTest.java | 90 final ListeningExecutorService executor = in testSameThreadExecutorServiceInThreadExecution() local
113 Future<?> future = executor.submit(incrementTask); in testSameThreadExecutorServiceInThreadExecution()
124 ListenableFuture<?> future = executor.submit(incrementTask); in testSameThreadExecutorServiceInThreadExecution()
137 final ExecutorService executor = MoreExecutors.sameThreadExecutor(); in testSameThreadExecutorInvokeAll() local
155 executor.invokeAll(Collections.nCopies(10, incrementTask)); in testSameThreadExecutorInvokeAll()
168 final ExecutorService executor = MoreExecutors.sameThreadExecutor(); in testSameThreadExecutorServiceTermination() local
180 Future<?> future = executor.submit(new Callable<Void>() { in testSameThreadExecutorServiceTermination()
188 assertTrue(executor.isShutdown()); in testSameThreadExecutorServiceTermination()
189 assertFalse(executor.isTerminated()); in testSameThreadExecutorServiceTermination()
197 assertTrue(executor.isShutdown()); in testSameThreadExecutorServiceTermination()
[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
157 @Override protected ScheduledExecutorService executor() { in testDefaultExecutorIsShutdownWhenServiceIsStopped()
159 executorService = super.executor(); in testDefaultExecutorIsShutdownWhenServiceIsStopped()
175 assertFalse(service.executor().isShutdown()); in testDefaultExecutorIsShutdownWhenServiceIsStopped()
179 assertTrue(service.executor().isShutdown()); in testDefaultExecutorIsShutdownWhenServiceIsStopped()
180 assertTrue(service.executor().awaitTermination(100, TimeUnit.MILLISECONDS)); in testDefaultExecutorIsShutdownWhenServiceIsStopped()
193 @Override protected ScheduledExecutorService executor() { in testDefaultExecutorIsShutdownWhenServiceFails()
195 executorService = super.executor(); in testDefaultExecutorIsShutdownWhenServiceFails()
215 assertTrue(service.executor().isShutdown()); in testDefaultExecutorIsShutdownWhenServiceFails()
[all …]
|
| D | SerializingExecutorTest.java | 148 final SerializingExecutor executor = new SerializingExecutor( in testDelegateRejection() local
164 executor.execute(task); in testDelegateRejection()
169 executor.execute(task); in testDelegateRejection()
179 final SerializingExecutor executor = new SerializingExecutor(service); in testTaskThrowsError() local
196 executor.execute(errorTask); in testTaskThrowsError()
201 executor.execute(barrierTask); in testTaskThrowsError()
|
| 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
376 return executor; in executor()
380 executor.shutdown(); in tearDown()
|
| D | AbstractFutureTest.java | 109 ExecutorService executor = Executors.newFixedThreadPool(10); in testCompletionFinishesWithDone() local
113 executor.execute(new Runnable() { in testCompletionFinishesWithDone()
122 executor.execute(new Runnable() { in testCompletionFinishesWithDone()
131 executor.execute(new Runnable() { in testCompletionFinishesWithDone()
148 executor.shutdown(); in testCompletionFinishesWithDone()
|
| /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() argument
52 this.executor = checkNotNull(executor); in AsyncEventBus()
66 public AsyncEventBus(Executor executor, SubscriberExceptionHandler subscriberExceptionHandler) { in AsyncEventBus() argument
68 this.executor = checkNotNull(executor); in AsyncEventBus()
79 public AsyncEventBus(Executor executor) { in AsyncEventBus() argument
81 this.executor = checkNotNull(executor); in AsyncEventBus()
113 executor.execute( in dispatch()
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | ExecutionList.java | 81 public void add(Runnable runnable, Executor executor) { in add() argument
86 Preconditions.checkNotNull(executor, "Executor was null."); in add()
93 runnables = new RunnableExecutorPair(runnable, executor, runnables); in add()
101 executeListener(runnable, executor); in add()
145 executeListener(reversedList.runnable, reversedList.executor); in execute()
154 private static void executeListener(Runnable runnable, Executor executor) { in executeListener() argument
156 executor.execute(runnable); in executeListener()
162 + runnable + " with executor " + executor, e); in executeListener()
168 final Executor executor; field in ExecutionList.RunnableExecutorPair
171 RunnableExecutorPair(Runnable runnable, Executor executor, RunnableExecutorPair next) { in RunnableExecutorPair() argument
[all …]
|
| D | AbstractScheduledService.java | 123 public Future<?> schedule(AbstractService service, ScheduledExecutorService executor, in newFixedDelaySchedule()
125 return executor.scheduleWithFixedDelay(task, initialDelay, delay, unit); in newFixedDelaySchedule()
142 public Future<?> schedule(AbstractService service, ScheduledExecutorService executor, in newFixedRateSchedule()
144 return executor.scheduleAtFixedRate(task, initialDelay, period, unit); in newFixedRateSchedule()
150 abstract Future<?> schedule(AbstractService service, ScheduledExecutorService executor,
189 executorService = MoreExecutors.renamingDecorator(executor(), new Supplier<String>() {
284 protected ScheduledExecutorService executor() {
285 final ScheduledExecutorService executor = Executors.newSingleThreadScheduledExecutor(
298 executor.shutdown();
301 executor.shutdown();
[all …]
|
| D | MoreExecutors.java | 85 ThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) { in getExitingExecutorService() argument
87 .getExitingExecutorService(executor, terminationTimeout, timeUnit); in getExitingExecutorService()
108 ScheduledThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) { in getExitingScheduledExecutorService() argument
110 .getExitingScheduledExecutorService(executor, terminationTimeout, timeUnit); in getExitingScheduledExecutorService()
147 public static ExecutorService getExitingExecutorService(ThreadPoolExecutor executor) { in getExitingExecutorService() argument
148 return new Application().getExitingExecutorService(executor); in getExitingExecutorService()
168 ScheduledThreadPoolExecutor executor) { in getExitingScheduledExecutorService() argument
169 return new Application().getExitingScheduledExecutorService(executor); in getExitingScheduledExecutorService()
176 ThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) { in getExitingExecutorService() argument
177 useDaemonThreadFactory(executor); in getExitingExecutorService()
[all …]
|
| D | SerializingExecutor.java | 51 private final Executor executor; field in SerializingExecutor
76 public SerializingExecutor(Executor executor) { in SerializingExecutor() argument
77 Preconditions.checkNotNull(executor, "'executor' must not be null."); in SerializingExecutor()
78 this.executor = executor; in SerializingExecutor()
106 executor.execute(taskRunner); in execute()
|
| D | ListenerCallQueue.java | 60 private final Executor executor; field in ListenerCallQueue
65 ListenerCallQueue(L listener, Executor executor) { in ListenerCallQueue() argument
67 this.executor = checkNotNull(executor); in ListenerCallQueue()
86 executor.execute(this); in execute()
94 "Exception while running callbacks for " + listener + " on " + executor, in execute()
|
| D | AbstractExecutionThreadService.java | 46 Executor executor = MoreExecutors.renamingDecorator(executor(), new Supplier<String>() {
51 executor.execute(new Runnable() {
142 protected Executor executor() { in executor() method in AbstractExecutionThreadService
192 @Override public final void addListener(Listener listener, Executor executor) {
193 delegate.addListener(listener, executor);
|
| D | AbstractIdleService.java | 50 MoreExecutors.renamingDecorator(executor(), threadNameSupplier)
65 MoreExecutors.renamingDecorator(executor(), threadNameSupplier)
97 protected Executor executor() { in executor() method in AbstractIdleService
146 @Override public final void addListener(Listener listener, Executor executor) {
147 delegate.addListener(listener, executor);
|
| 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()
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
| D | DispatcherTest.java | 17 RecordingExecutor executor = new RecordingExecutor(); field in DispatcherTest
19 Dispatcher dispatcher = new Dispatcher(executor);
45 executor.assertJobs("http://a/1"); in enqueuedJobsRunImmediately()
54 executor.assertJobs("http://a/1", "http://a/2", "http://b/1"); in maxRequestsEnforced()
62 executor.assertJobs("http://a/1", "http://a/2"); in maxPerHostEnforced()
73 executor.assertJobs("http://a/1", "http://b/1", "http://c/1", "http://a/2"); in increasingMaxRequestsPromotesJobsImmediately()
84 executor.assertJobs("http://a/1", "http://a/2", "http://a/3", "http://a/4"); in increasingMaxPerHostPromotesJobsImmediately()
91 executor.finishJob("http://a/1"); in oldJobFinishesNewJobCanRunDifferentHost()
92 executor.assertJobs("http://b/1"); in oldJobFinishesNewJobCanRunDifferentHost()
102 executor.finishJob("http://a/1"); in oldJobFinishesNewJobWithSameHostStarts()
[all …]
|
| /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/guava/guava-testlib/test/com/google/common/util/concurrent/testing/ |
| D | TestingExecutorsTest.java | 56 ListeningScheduledExecutorService executor = TestingExecutors.noOpScheduledExecutor(); in testNoOpScheduledExecutorShutdown() local
57 assertFalse(executor.isShutdown()); in testNoOpScheduledExecutorShutdown()
58 assertFalse(executor.isTerminated()); in testNoOpScheduledExecutorShutdown()
59 executor.shutdown(); in testNoOpScheduledExecutorShutdown()
60 assertTrue(executor.isShutdown()); in testNoOpScheduledExecutorShutdown()
61 assertTrue(executor.isTerminated()); in testNoOpScheduledExecutorShutdown()
65 ListeningScheduledExecutorService executor = TestingExecutors.noOpScheduledExecutor(); in testNoOpScheduledExecutorInvokeAll() local
73 List<Future<Boolean>> futureList = executor.invokeAll( in testNoOpScheduledExecutorInvokeAll()
|
| /external/jmonkeyengine/engine/src/bullet-common/com/jme3/bullet/ |
| D | BulletAppState.java | 26 protected ScheduledThreadPoolExecutor executor; field in BulletAppState
71 if (executor != null) { in startPhysicsOnExecutor()
72 executor.shutdown(); in startPhysicsOnExecutor()
74 executor = new ScheduledThreadPoolExecutor(1); in startPhysicsOnExecutor()
86 return executor.submit(call).get(); in startPhysicsOnExecutor()
110 …executor.schedule(detachedPhysicsUpdate, Math.round(getPhysicsSpace().getAccuracy() * 1000000.0f) …
183 physicsFuture = executor.submit(parallelPhysicsUpdate); in render()
204 if (executor != null) { in cleanup()
205 executor.shutdown(); in cleanup()
206 executor = null; in cleanup()
|
| /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 | 35 private FakeExecutor executor; field in AsyncEventBusTest
40 executor = new FakeExecutor(); in setUp()
41 bus = new AsyncEventBus(executor); in setUp()
56 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/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/guava/guava/src/com/google/common/cache/ |
| D | RemovalListeners.java | 45 final RemovalListener<K, V> listener, final Executor executor) { in asynchronous() argument
47 checkNotNull(executor); in asynchronous()
51 executor.execute(new Runnable() { in asynchronous()
|
| /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()
|