| /external/tensorflow/tensorflow/core/kernels/hexagon/ |
| hexagon_remote_fused_graph_executor_build_test.cc | 25 std::unique_ptr<IRemoteFusedGraphExecutor>* executor);
30 std::unique_ptr<IRemoteFusedGraphExecutor> executor; local
31 ASSERT_FALSE(static_cast<bool>(executor));
32 TF_ASSERT_OK(BuildRemoteFusedGraphExecutor(&executor));
33 ASSERT_TRUE(static_cast<bool>(executor));
|
| /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;
|
| /tools/apkzlib/src/main/java/com/android/tools/build/apkzlib/zip/compress/ |
| ExecutorCompressor.java | 24 import java.util.concurrent.Executor;
34 * The executor that does the work.
37 private final Executor executor; field in class:ExecutorCompressor
40 * Compressor that delegates execution into the given executor.
41 * @param executor the executor that will do the compress
43 public ExecutorCompressor(@Nonnull Executor executor) {
44 this.executor = executor
[all...] |
| /dalvik/dx/tests/127-merge-stress/com/android/dx/merge/ |
| MergeTest.java | 44 private static final ExecutorService executor = Executors.newFixedThreadPool(WORKER_THREADS); field in class:MergeTest
99 executor.execute(new MergeTask(fileNames, dexesToMerge));
102 executor.shutdown();
103 executor.awaitTermination(8, TimeUnit.HOURS);
|
| /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 | 27 XmlActionExecutor executor; local
28 XmlNodeAction& manifest_action = executor["manifest"];
47 ASSERT_TRUE(executor.Execute(XmlActionExecutorPolicy::kNone, &diag, doc.get()));
56 XmlActionExecutor executor; local
57 executor["manifest"]["application"];
63 ASSERT_FALSE(executor.Execute(XmlActionExecutorPolicy::kWhitelist, &diag, doc.get()));
66 ASSERT_FALSE(executor.Execute(XmlActionExecutorPolicy::kWhitelist, &diag, doc.get()));
|
| /frameworks/support/app-toolkit/core-testing/src/main/java/androidx/arch/core/executor/testing/ |
| InstantTaskExecutorRule.java | 17 package androidx.arch.core.executor.testing;
19 import androidx.arch.core.executor.ArchTaskExecutor;
20 import androidx.arch.core.executor.TaskExecutor;
26 * A JUnit Test Rule that swaps the background executor used by the Architecture Components with a
|
| /packages/apps/Contacts/src/com/android/contacts/util/concurrent/ |
| FuturesUtil.java | 39 TimeUnit unit, ScheduledExecutorService executor) {
41 executor.schedule(new Runnable() {
|
| /packages/apps/DocumentsUI/tests/common/com/android/documentsui/testing/ |
| TestImmediateExecutor.java | 21 import java.util.concurrent.Executor;
24 * An {@link Executor} that executes command in place.
26 public class TestImmediateExecutor implements Executor {
32 public static Lookup<String, Executor> createLookup() {
33 final TestImmediateExecutor executor = new TestImmediateExecutor(); local
35 return executor;
|
| /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 | 24 private final ScheduledExecutorService executor; field in class:DelayedExecution
27 this.executor = newScheduledThreadPool(CORE_POOL_SIZE, maxPrioThreadFactory());
33 executor.submit(delayedExecution(r, deadline));
37 executor.shutdownNow();
39 if (!executor.awaitTermination(5, SECONDS)) {
|
