Home
last modified time | relevance | path

Searched full:executors (Results 1 – 25 of 492) sorted by relevance

12345678910>>...20

/external/grpc-grpc/src/core/lib/iomgr/
Dexecutor.cc319 static GrpcExecutor* executors[GRPC_NUM_EXECUTORS]; variable
322 executors[GRPC_DEFAULT_EXECUTOR]->Enqueue(closure, error, in default_enqueue_short()
327 executors[GRPC_DEFAULT_EXECUTOR]->Enqueue(closure, error, in default_enqueue_long()
332 executors[GRPC_RESOLVER_EXECUTOR]->Enqueue(closure, error, in resolver_enqueue_short()
337 executors[GRPC_RESOLVER_EXECUTOR]->Enqueue(closure, error, in resolver_enqueue_long()
362 if (executors[GRPC_DEFAULT_EXECUTOR] != nullptr) { in grpc_executor_init()
363 GPR_ASSERT(executors[GRPC_RESOLVER_EXECUTOR] != nullptr); in grpc_executor_init()
367 executors[GRPC_DEFAULT_EXECUTOR] = in grpc_executor_init()
369 executors[GRPC_RESOLVER_EXECUTOR] = in grpc_executor_init()
372 executors[GRPC_DEFAULT_EXECUTOR]->Init(); in grpc_executor_init()
[all …]
Dexecutor.h85 // TODO(sreek): Currently we have two executors (available globally): The
89 // operate of ALL the executors. This is a bit confusing and should be cleaned
93 // Initialize ALL the executors
96 // Shutdown ALL the executors
99 // Set the threading mode for ALL the executors
/external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/
Dexecutor.cc58 Executor* executors[static_cast<size_t>(ExecutorType::NUM_EXECUTORS)]; variable
61 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Enqueue( in default_enqueue_short()
66 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Enqueue( in default_enqueue_long()
71 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Enqueue( in resolver_enqueue_short()
76 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Enqueue( in resolver_enqueue_long()
390 if (executors[static_cast<size_t>(ExecutorType::DEFAULT)] != nullptr) { in InitAll()
391 GPR_ASSERT(executors[static_cast<size_t>(ExecutorType::RESOLVER)] != in InitAll()
396 executors[static_cast<size_t>(ExecutorType::DEFAULT)] = in InitAll()
398 executors[static_cast<size_t>(ExecutorType::RESOLVER)] = in InitAll()
401 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Init(); in InitAll()
[all …]
Dexecutor.h75 // TODO(sreek): Currently we have two executors (available globally): The
79 // operate of ALL the executors. This is a bit confusing and should be cleaned
83 // Initialize ALL the executors
90 // Shutdown ALL the executors
93 // Set the threading mode for ALL the executors
96 // Set the threading mode for ALL the executors
/external/autotest/server/cros/tradefed/tradefed_utils_unittest_data/
DGtsPlacementTestCases.txt52 at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:428)
88 at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:428)
114 at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:428)
134 at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:428)
160 at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:428)
180 at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:428)
243 at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:428)
279 at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:428)
305 at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:428)
325 at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:428)
[all …]
DCtsAppTestCases-retry.txt51 at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:428)
74 at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:428)
110 at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:428)
132 at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:428)
170 at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:428)
194 at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:428)
232 at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:428)
256 at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:428)
/external/tensorflow/tensorflow/compiler/xla/stream_executor/
Dexecutor_cache.h47 // Destroys all Executors and clears the cache.
48 // Performs no synchronization with the executors - undefined behavior may
49 // occur if any executors are active!
53 // Each Entry contains zero or more cached executors for a device ordinal.
69 // Maps ordinal number to a list of cached executors for that ordinal.
Dexecutor_cache.cc76 // Need to iterate through all stored executors. in Get()
87 absl::StrFormat("No executors own stream %p", config.gpu_stream)); in Get()
97 absl::StrFormat("No executors registered for ordinal %d", in Get()
105 absl::StrFormat("No executors registered for ordinal %d", in Get()
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/
DWithTimeoutOrNullThreadDispatchTest.kt9 import java.util.concurrent.Executors
25 executor = Executors.newScheduledThreadPool(1, it) in testCancellationDispatchScheduled()
33 executor = Executors.newSingleThreadExecutor(it) in testCancellationDispatchNonScheduled()
43 executor = Executors.newSingleThreadExecutor(it) in testCancellationDispatchCustomNoDelay()
DWithTimeoutThreadDispatchTest.kt9 import java.util.concurrent.Executors
25 executor = Executors.newScheduledThreadPool(1, it) in testCancellationDispatchScheduled()
33 executor = Executors.newSingleThreadExecutor(it) in testCancellationDispatchNonScheduled()
43 executor = Executors.newSingleThreadExecutor(it) in testCancellationDispatchCustomNoDelay()
DFailingCoroutinesMachineryTest.kt103 …TestDispatcher("Executors.newFixedThreadPool(1)") { Executors.newFixedThreadPool(1).asCoroutineDis… in <lambda>()
104 …TestDispatcher("Executors.newScheduledThreadPool(1)") { Executors.newScheduledThreadPool(1).asCoro… in <lambda>()
/external/downloader/src/test/java/com/google/android/downloader/
DTestExecutorRule.java27 import java.util.concurrent.Executors;
35 * down any started threads and executors during execution, and also collects uncaught exceptions,
44 Thread thread = Executors.defaultThreadFactory().newThread(runnable);
68 ExecutorService executorService = Executors.newSingleThreadExecutor(threadFactory); in newSingleThreadExecutor()
82 Executors.newSingleThreadScheduledExecutor(threadFactory); in newSingleThreadScheduledExecutor()
/external/connectedappssdk/tests/shared/src/main/java/com/google/android/enterprise/connectedapps/
DSharedTestUtilities.java27 import java.util.concurrent.Executors;
86 .withTimeout(1, TimeUnit.SECONDS, Executors.newSingleThreadScheduledExecutor()) in assertFutureDoesNotHaveException()
103 ExecutorService executorA = Executors.newSingleThreadExecutor(); in tryForceRaceCondition()
104 ExecutorService executorB = Executors.newSingleThreadExecutor(); in tryForceRaceCondition()
/external/guice/extensions/servlet/test/com/google/inject/servlet/
DTransferRequestIntegrationTest.java28 import java.util.concurrent.Executors;
104 ExecutorService executor = Executors.newSingleThreadExecutor(); in testTransferNonHttpRequest()
144 ExecutorService executor = Executors.newSingleThreadExecutor(); in testTransferNonHttpRequest_closeable()
159 ExecutorService executor = Executors.newSingleThreadExecutor(); in testTransferNonHttpRequest_concurrentUseBlocks()
184 ExecutorService executor = Executors.newSingleThreadExecutor(); in testTransferNonHttpRequest_concurrentUseBlocks_closeable()
/external/tensorflow/tensorflow/core/common_runtime/
Dexecutor.h66 // run. Executors on different devices may receive the same step_id
148 // A class to help run multiple executors in parallel and wait until
157 // Create an ExecutorBarrier for 'num' different executors.
160 // state. If any of the executors experiences an error, the
170 // Returns a closure that Executors must call when they are done
217 errors::Aborted("Stopping remaining executors.")); in WhenDone()
/external/robolectric/robolectric/src/test/java/org/robolectric/shadows/
DShadowWifiManagerTest.java47 import java.util.concurrent.Executors;
927 Executors.newSingleThreadExecutor(), in setExternalPnoScanRequest_nullCallback_throwsIllegalArgumentException()
953 Executors.newSingleThreadExecutor(), in setExternalPnoScanRequest_nullSsidList_throwsIllegalStateException()
966 Executors.newSingleThreadExecutor(), in setExternalPnoScanRequest_emptySsidList_throwsIllegalStateException()
982 Executors.newSingleThreadExecutor(), in setExternalPnoScanRequest_moreThan2Ssids_throwsIllegalArgumentException()
997 Executors.newSingleThreadExecutor(), in setExternalPnoScanRequest_moreThan10Frequencies_throwsIllegalArgumentException()
1009 Executors.newSingleThreadExecutor(), in setExternalPnoScanRequest_validRequest_successCallbackInvoked()
1025 Executors.newSingleThreadExecutor(), in setExternalPnoScanRequest_outstandingRequest_failureCallbackInvokedWithAlreadyRegisteredStatus()
1031 Executors.newSingleThreadExecutor(), in setExternalPnoScanRequest_outstandingRequest_failureCallbackInvokedWithAlreadyRegisteredStatus()
1047 Executors.newSingleThreadExecutor(), in setExternalPnoScanRequest_differentUid_failureCallbackInvokedWithBusyStatus()
[all …]
/external/volley/core/src/main/java/com/android/volley/
DAsyncRequestQueue.java33 import java.util.concurrent.Executors;
79 * This interface may be used by advanced applications to provide custom executors according to
109 * @param executorFactory Interface to be used to provide custom executors according to the
124 /** Sets the executors and initializes the cache. */
129 // Create blocking / non-blocking executors and set them in the network and stack. in start()
170 /** Shuts down and nullifies both executors */
490 * Factory to create/provide the executors which Volley will use.
492 * <p>This class may be used by advanced applications to provide custom executors according to
510 /** Provides a BlockingQueue to be used to create executors. */
622 Thread t = Executors.defaultThreadFactory().newThread(runnable);
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/
DThreadPoolDispatcher.kt29 * JDK executors, use the following expression: in <lambda>()
30 * `Executors.newFixedThreadPool().asCoroutineDispatcher()`. in <lambda>()
40 val executor = Executors.newScheduledThreadPool(nThreads) { runnable -> in <lambda>()
/external/apache-commons-io/src/test/java/org/apache/commons/io/function/
DIORunnableTest.java27 import java.util.concurrent.Executors;
53 …assertThrows(UncheckedIOException.class, () -> Executors.callable(TestConstants.THROWING_IO_RUNNAB… in testAsRunnable()
55 assertNull(Executors.callable(runnable.asRunnable()).call()); in testAsRunnable()
/external/robolectric/shadows/framework/src/main/java/org/robolectric/android/util/concurrent/
DPausedExecutorService.java14 import java.util.concurrent.Executors;
80 Executors.newSingleThreadExecutor( in PausedExecutorService()
167 deferredTasks.add(new DeferredTask<>(Executors.callable(command), realService)); in execute()
173 return newTaskFor(Executors.callable(runnable, value)); in newTaskFor()
/external/tensorflow/tensorflow/compiler/xla/service/
Dlocal_service.cc184 // BuildExecutables uses the executors length to determine the number of in CompileExecutables()
186 std::vector<se::StreamExecutor*> executors(build_options.num_partitions(), in CompileExecutables() local
191 execute_backend_.get(), {executors}, in CompileExecutables()
213 // BuildAotResults uses the executors length to determine the number of in CompileAotResults()
215 std::vector<se::StreamExecutor*> executors(build_options.num_partitions(), in CompileAotResults() local
220 execute_backend_.get(), {executors}, in CompileAotResults()
/external/rust/crates/futures-task/src/
Darc_wake.rs7 /// Those Wakers can be used to signal executors that a task it owns
27 /// Executors generally maintain a queue of "ready" tasks; `wake` should place
41 /// Executors generally maintain a queue of "ready" tasks; `wake_by_ref` should place
/external/libchrome/mojo/public/java/bindings/src/org/chromium/mojo/bindings/
DExecutorFactory.java23 * A factory which provides per-thread executors, which enable execution on the thread from which
156 private static final ThreadLocal<Executor> EXECUTORS = new ThreadLocal<Executor>(); field in ExecutorFactory
162 Executor executor = EXECUTORS.get(); in getExecutorForCurrentThread()
165 EXECUTORS.set(executor); in getExecutorForCurrentThread()
/external/guice/extensions/service/test/com/google/inject/service/
DSingleServiceIntegrationTest.java6 import java.util.concurrent.Executors;
18 ExecutorService executor = Executors.newSingleThreadExecutor(); in testAsyncServiceLifecycle()
60 ExecutorService executor = Executors.newSingleThreadExecutor(); in testAsyncServiceBlockingLifecycle()
/external/mockito/src/test/java/org/mockitousage/bugs/
DShouldNotDeadlockAnswerExecutionTest.java15 import java.util.concurrent.Executors;
25 ExecutorService threads = Executors.newCachedThreadPool(); in failIfMockIsSharedBetweenThreads()
51 ExecutorService threads = Executors.newCachedThreadPool(); in successIfEveryThreadHasItsOwnMock()

12345678910>>...20