/packages/inputmethods/LatinIME/native/dicttoolkit/ |
dict_toolkit_main.cpp | 37 const auto executor = CommandUtils::getCommandExecutor(commandType); local 38 return executor(argc - 1, argv + 1);
|
/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...] |
/packages/inputmethods/LatinIME/tests/src/com/android/inputmethod/latin/utils/ |
ExecutorUtilsTests.java | 38 final ExecutorService executor = local 42 executor.execute(new Runnable() { 50 executor.awaitTermination(DELAY_FOR_WAITING_TASKS_MILLISECONDS, TimeUnit.MILLISECONDS);
|
/external/vogar/src/vogar/target/junit/ |
TimeoutAndAbortRunRule.java | 37 private final ExecutorService executor = Executors.newCachedThreadPool( field in class:TimeoutAndAbortRunRule 68 Future<Throwable> result = executor.submit(new Callable<Throwable>() {
|
/external/webrtc/webrtc/examples/androidtests/src/org/appspot/apprtc/test/ |
LooperExecutorTest.java | 38 LooperExecutor executor = new LooperExecutor(); local 40 // Try to execute a counter increment task before starting an executor. 41 executor.execute(counterIncRunnable); 43 // Start the executor and run expected amount of counter increment task. 44 executor.requestStart(); 46 executor.execute(counterIncRunnable); 48 executor.execute(new Runnable() { 54 executor.requestStop(); 56 // Try to execute a task after stopping the executor. 57 executor.execute(counterIncRunnable) [all...] |
/external/guava/guava/src/com/google/common/eventbus/ |
AsyncEventBus.java | 24 import java.util.concurrent.Executor; 27 * An {@link EventBus} that takes the Executor of your choice and uses it to 35 private final Executor executor; field in class:AsyncEventBus 42 * Creates a new AsyncEventBus that will use {@code executor} to dispatch 46 * @param executor Executor to use to dispatch events. It is the caller's 47 * responsibility to shut down the executor after the last event has 50 public AsyncEventBus(String identifier, Executor executor) { [all...] |
/external/jacoco/org.jacoco.agent.rt.test/src/org/jacoco/agent/rt/internal/output/ |
ExecutorTestBase.java | 16 import java.util.concurrent.Executor; 27 * Unit tests base for tests that need an {@link Executor} for multithreaded 32 protected ExecutorService executor; field in class:ExecutorTestBase 36 executor = Executors.newSingleThreadExecutor(); 41 executor.shutdown();
|
/external/okhttp/samples/guide/src/main/java/com/squareup/okhttp/recipes/ |
CancelCall.java | 28 private final ScheduledExecutorService executor = Executors.newScheduledThreadPool(1); field in class:CancelCall 40 executor.schedule(new Runnable() {
|
/packages/apps/Launcher3/tests/src/com/android/launcher3/util/ |
Condition.java | 19 final MainThreadExecutor executor = new MainThreadExecutor(); local 26 executor.execute(new Runnable() {
|
/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;
|
/external/vogar/src/vogar/target/ |
TestActivity.java | 66 ExecutorService executor = Threads.fixedThreadsExecutor(log, "testactivity", 1); local 67 executor.execute(new Runnable() { 79 executor.shutdown();
|
/external/dagger2/compiler/src/it/producers-functional-tests/src/main/java/producerstest/builder/ |
TestComponentWithBuilder.java | 20 import java.util.concurrent.Executor; 34 Builder executor(Executor executor); method in interface:TestComponentWithBuilder.Builder
|
/external/glide/library/src/main/java/com/bumptech/glide/load/engine/executor/ |
Prioritized.java | 1 package com.bumptech.glide.load.engine.executor;
|
/external/guava/guava-testlib/test/com/google/common/util/concurrent/testing/ |
TestingExecutorsTest.java | 56 ListeningScheduledExecutorService executor = TestingExecutors.noOpScheduledExecutor(); local 57 assertFalse(executor.isShutdown()); 58 assertFalse(executor.isTerminated()); 59 executor.shutdown(); 60 assertTrue(executor.isShutdown()); 61 assertTrue(executor.isTerminated()); 65 ListeningScheduledExecutorService executor = TestingExecutors.noOpScheduledExecutor(); local 73 List<Future<Boolean>> futureList = executor.invokeAll(
|
/external/guice/extensions/service/src/com/google/inject/service/ |
AsyncService.java | 37 private final ExecutorService executor; field in class:AsyncService 41 public AsyncService(ExecutorService executor) { 42 this.executor = executor; 54 return executor.submit(new Callable<State>() { 79 return executor.submit(new Callable<State>() {
|
/frameworks/base/tools/aapt2/xml/ |
XmlActionExecutor_test.cpp | 25 XmlActionExecutor executor; local 26 XmlNodeAction& manifest_action = executor["manifest"]; 46 executor.Execute(XmlActionExecutorPolicy::kNone, &diag, doc.get())); 55 XmlActionExecutor executor; local 56 executor["manifest"]["application"]; 62 executor.Execute(XmlActionExecutorPolicy::kWhitelist, &diag, doc.get()));
|
/packages/apps/Contacts/src/com/android/contacts/util/concurrent/ |
FuturesUtil.java | 39 TimeUnit unit, ScheduledExecutorService executor) { 41 executor.schedule(new Runnable() {
|
/external/guice/extensions/service/test/com/google/inject/service/ |
SingleServiceIntegrationTest.java | 22 ExecutorService executor = Executors.newSingleThreadExecutor(); local 26 AsyncService service = new AsyncService(executor) { 54 executor.shutdown(); 61 ExecutorService executor = Executors.newSingleThreadExecutor(); local 64 AsyncService service = new AsyncService(executor) { 77 executor.shutdown();
|
/external/guice/extensions/servlet/test/com/google/inject/servlet/ |
TransferRequestIntegrationTest.java | 87 ExecutorService executor = Executors.newSingleThreadExecutor(); local 88 assertTrue(executor.submit(transfer).get()); 89 executor.shutdownNow(); 95 ExecutorService executor = Executors.newSingleThreadExecutor(); 97 Future<Boolean> future = executor.submit(ServletScopes.transferRequest(FALSE_CALLABLE)); 104 executor.shutdownNow();
|
/external/mockito/src/test/java/org/mockitousage/verification/ |
DelayedExecution.java | 20 private final ScheduledExecutorService executor; field in class:DelayedExecution 23 this.executor = newScheduledThreadPool(CORE_POOL_SIZE, maxPrioThreadFactory()); 29 executor.submit(delayedExecution(r, deadline)); 33 executor.shutdownNow(); 35 if (!executor.awaitTermination(5, SECONDS)) {
|
/libcore/ojluni/src/main/java/java/util/concurrent/ |
ExecutorCompletionService.java | 39 * A {@link CompletionService} that uses a supplied {@link Executor} 56 * void solve(Executor e, 76 * void solve(Executor e, 107 private final Executor executor; field in class:ExecutorCompletionService 142 * executor for base task execution and a 145 * @param executor the executor to use 146 * @throws NullPointerException if executor is {@code null} 148 public ExecutorCompletionService(Executor executor) [all...] |
/cts/tests/sensor/src/android/hardware/cts/helpers/sensoroperations/ |
ParallelSensorOperation.java | 86 ThreadPoolExecutor executor = new ThreadPoolExecutor( local 92 executor.allowCoreThreadTimeOut(true); 93 executor.prestartAllCoreThreads(); 98 Future<SensorOperation> future = executor.submit(new Callable<SensorOperation>() { 135 executor.shutdownNow();
|
/external/okhttp/samples/crawler/src/main/java/com/squareup/okhttp/sample/ |
Crawler.java | 53 ExecutorService executor = Executors.newFixedThreadPool(threadCount); local 55 executor.execute(new NamedRunnable("Crawler %s", i) { 65 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());
|
/libcore/luni/src/test/java/libcore/java/lang/ref/ |
ReferenceQueueTest.java | 124 ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(1); local 125 executor.schedule(runnable, delayMillis, TimeUnit.MILLISECONDS); 126 executor.shutdown();
|