| /packages/apps/QuickSearchBox/src/com/android/quicksearchbox/util/ |
| PerNameExecutor.java | 23 * Uses a separate executor for each task name.
39 for (NamedTaskExecutor executor : mExecutors.values()) {
40 executor.cancelPendingTasks();
46 for (NamedTaskExecutor executor : mExecutors.values()) {
47 executor.close();
56 NamedTaskExecutor executor = mExecutors.get(name); local
57 if (executor == null) {
58 executor = mExecutorFactory.create();
59 mExecutors.put(name, executor);
61 executor.execute(task)
[all...] |
| /external/guava/guava/src/com/google/common/eventbus/ |
| AsyncEventBus.java | 21 import java.util.concurrent.Executor;
24 * An {@link EventBus} that takes the Executor of your choice and uses it to
32 private final Executor executor; field in class:AsyncEventBus
39 * Creates a new AsyncEventBus that will use {@code executor} to dispatch
43 * @param executor Executor to use to dispatch events. It is the caller's
44 * responsibility to shut down the executor after the last event has
47 public AsyncEventBus(String identifier, Executor executor) {
[all...] |
| /packages/apps/QuickSearchBox/tests/src/com/android/quicksearchbox/util/ |
| MockNamedTaskExecutorFactory.java | 30 * Runs one task in each executor.
33 for (MockNamedTaskExecutor executor : mExecutors) {
34 executor.runNext();
39 MockNamedTaskExecutor executor = new MockNamedTaskExecutor(); local
40 mExecutors.add(executor);
41 return executor;
|
| /libcore/luni/src/test/java/libcore/java/lang/ref/ |
| ReferenceQueueTest.java | 93 ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(1); local
94 executor.schedule(runnable, delayMillis, TimeUnit.MILLISECONDS);
95 executor.shutdown();
|
| /packages/inputmethods/LatinIME/tests/src/com/android/inputmethod/latin/utils/ |
| ExecutorUtilsTests.java | 39 final ExecutorService executor = ExecutorUtils.getExecutor(TEST_EXECUTOR_ID); local
42 executor.execute(new Runnable() {
50 executor.awaitTermination(DELAY_FOR_WAITING_TASKS_MILLISECONDS, TimeUnit.MILLISECONDS);
|
| /external/glide/library/src/main/java/com/bumptech/glide/load/engine/executor/ |
| Prioritized.java | 1 package com.bumptech.glide.load.engine.executor;
|
| FifoPriorityThreadPoolExecutor.java | 1 package com.bumptech.glide.load.engine.executor;
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| AbstractIdleService.java | 22 import java.util.concurrent.Executor;
28 * which run in a executor which by default uses a separate thread
40 executor(State.STARTING).execute(new Runnable() {
54 executor(State.STOPPING).execute(new Runnable() {
75 * Returns the {@link Executor} that will be used to run this service.
76 * Subclasses may override this method to use a custom {@link Executor}, which
78 * priority. The returned executor's {@link Executor#execute(Runnable)
86 protected Executor executor(final State state) method in class:AbstractIdleService
[all...] |
| AbstractExecutionThreadService.java | 22 import java.util.concurrent.Executor;
43 executor().execute(new Runnable() {
112 * Returns the {@link Executor} that will be used to run this service.
113 * Subclasses may override this method to use a custom {@link Executor}, which
115 * priority. The returned executor's {@link Executor#execute(Runnable)
119 * <p>The default implementation returns a new {@link Executor} that sets the
122 protected Executor executor() { method in class:AbstractExecutionThreadService
123 return new Executor() {
[all...] |
| /libcore/luni/src/main/java/java/util/concurrent/ |
| ExecutorCompletionService.java | 10 * A {@link CompletionService} that uses a supplied {@link Executor}
27 * void solve(Executor e,
47 * void solve(Executor e,
79 private final Executor executor; field in class:ExecutorCompletionService
111 * executor for base task execution and a
114 * @param executor the executor to use
115 * @throws NullPointerException if executor is {@code null}
117 public ExecutorCompletionService(Executor executor)
[all...] |
| /packages/inputmethods/LatinIME/java/src/com/android/inputmethod/latin/utils/ |
| ExecutorUtils.java | 42 return new Thread(r, "Executor - " + mId);
47 * Gets the executor for the given id.
50 ExecutorService executor = sExecutorMap.get(id); local
51 if (executor == null) {
53 executor = sExecutorMap.get(id);
54 if (executor == null) {
55 executor = Executors.newSingleThreadExecutor(new ThreadFactoryWithId(id));
56 sExecutorMap.put(id, executor);
60 return executor;
64 * Shutdowns all executors and removes all executors from the executor map for testing
[all...] |
| /cts/tests/tests/hardware/src/android/hardware/cts/helpers/sensoroperations/ |
| ParallelSensorOperation.java | 86 ThreadPoolExecutor executor = new ThreadPoolExecutor( local
92 executor.allowCoreThreadTimeOut(true);
93 executor.prestartAllCoreThreads();
97 Future<ISensorOperation> future = executor.submit(new Callable<ISensorOperation>() {
134 executor.shutdownNow();
|
| /external/chromium_org/third_party/WebKit/Source/devtools/scripts/jsdoc-validator/src/org/chromium/devtools/jsdoc/ |
| JsDocValidator.java | 20 ExecutorService executor = Executors.newFixedThreadPool(threadCount); local
22 runWithExecutor(args, executor);
24 executor.shutdown();
28 private void runWithExecutor(String[] args, ExecutorService executor) {
31 futures.add(executor.submit(new FileCheckerCallable(fileName)));
|
| /external/okhttp/samples/crawler/src/main/java/com/squareup/okhttp/sample/ |
| Crawler.java | 54 ExecutorService executor = Executors.newFixedThreadPool(threadCount); local
56 executor.execute(new Runnable() {
66 executor.shutdown();
|
| /external/owasp/sanitizer/src/tests/org/owasp/html/ |
| HtmlSanitizerFuzzerTest.java | 73 // Use an executor so that any infinite loops do not cause the test runner
75 ThreadPoolExecutor executor = new ThreadPoolExecutor( local
128 executor.execute(new Runnable() {
141 executor.shutdown();
142 executor.awaitTermination(runCount * 4, TimeUnit.SECONDS);
143 assertTrue("seed=" + seed, executor.isTerminated());
|
| /external/smack/src/org/jivesoftware/smackx/bytestreams/socks5/ |
| Socks5Client.java | 96 Thread executor = new Thread(futureTask);
local
97 executor.start();
|
| /libcore/luni/src/test/java/tests/security/ |
| SecureRandomTest.java | 79 ExecutorService executor = Executors.newFixedThreadPool(threads); local
80 ExecutorCompletionService ecs = new ExecutorCompletionService(executor);
91 executor.shutdown();
|
| /libcore/support/src/test/java/libcore/javax/net/ssl/ |
| TestSSLSocketPair.java | 79 ExecutorService executor = Executors.newFixedThreadPool(2); local
80 Future s = executor.submit(new Callable<Void>() {
89 Future c = executor.submit(new Callable<Void>() {
98 executor.shutdown();
|
| /packages/providers/CalendarProvider/src/com/android/providers/calendar/ |
| CalendarReceiver.java | 40 private final ExecutorService executor = Executors.newCachedThreadPool(); field in class:CalendarReceiver
55 executor.submit(new Runnable() {
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| MoreExecutorsTest.java | 49 final ListeningExecutorService executor = local
72 Future<?> future = executor.submit(incrementTask);
83 ListenableFuture<?> future = executor.submit(incrementTask);
96 final ExecutorService executor = MoreExecutors.sameThreadExecutor(); local
114 executor.invokeAll(Collections.nCopies(10, incrementTask));
127 final ExecutorService executor = MoreExecutors.sameThreadExecutor(); local
139 Future<?> future = executor.submit(new Callable<Void>() {
147 assertTrue(executor.isShutdown());
148 assertFalse(executor.isTerminated());
156 assertTrue(executor.isShutdown())
[all...] |
| /external/okhttp/benchmarks/src/main/java/com/squareup/okhttp/benchmarks/ |
| SynchronousHttpClient.java | 27 ThreadPoolExecutor executor; field in class:SynchronousHttpClient
32 executor = new ThreadPoolExecutor(benchmark.concurrencyLevel, benchmark.concurrencyLevel,
37 executor.execute(request(url));
41 return executor.getQueue().size() < targetBacklog;
|
| /frameworks/base/packages/DocumentsUI/src/com/android/documentsui/ |
| ProviderExecutor.java | 29 import java.util.concurrent.Executor;
32 public class ProviderExecutor extends Thread implements Executor {
39 ProviderExecutor executor = sExecutors.get(authority); local
40 if (executor == null) {
41 executor = new ProviderExecutor();
42 executor.setName("ProviderExecutor: " + authority);
43 executor.start();
44 sExecutors.put(authority, executor);
46 return executor;
87 private Executor mNonPreemptingExecutor = new Executor()
[all...] |
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/io/ |
| OutputStreamTesterTest.java | 116 private ExecutorService executor; field in class:OutputStreamTesterTest.PipedOutputStreamSinkTester
123 executor = Executors.newSingleThreadExecutor();
124 future = executor.submit(new Callable<byte[]>() {
141 executor.shutdown();
|
| WriterTesterTest.java | 109 private ExecutorService executor; field in class:WriterTesterTest.PipedWriterCharSinkTester
116 executor = Executors.newSingleThreadExecutor();
117 future = executor.submit(new Callable<char[]>() {
135 executor.shutdown();
|
| /external/guava/guava-tests/test/com/google/common/eventbus/ |
| AsyncEventBusTest.java | 21 import java.util.concurrent.Executor;
32 /** The executor we use to fake asynchronicity. */
33 private FakeExecutor executor; field in class:AsyncEventBusTest
38 executor = new FakeExecutor();
39 bus = new AsyncEventBus(executor);
46 // We post the event, but our Executor will not deliver it until instructed.
53 // Now we find the task in our Executor and explicitly activate it.
54 List<Runnable> tasks = executor.getTasks();
64 * An {@link Executor} wanna-be that simply records the tasks it's given.
65 * Arguably the Worst Executor Ever
[all...] |
