Home
last modified time | relevance | path

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

12345678910>>...15

/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/tensorflow/tensorflow/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.
/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/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>()
DExecutorsTest.kt40 val executor = Executors.newSingleThreadExecutor { r -> Thread(r, "TestExecutor") } in <lambda>()
51 …val executor: ExecutorService = Executors.newSingleThreadExecutor { r -> Thread(r, "TestExecutor")… in <lambda>()
101 val executorService = Executors.newSingleThreadExecutor { r -> Thread(r, "TestExecutor") } in <lambda>()
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/
DThreadPoolDispatcher.kt28 * JDK executors, use the following expression: in <lambda>()
29 * `Executors.newSingleThreadExecutor().asCoroutineDispatcher()`. in <lambda>()
54 * JDK executors, use the following expression: in <lambda>()
55 * `Executors.newFixedThreadPool().asCoroutineDispatcher()`. in <lambda>()
84 override val executor: Executor = Executors.newScheduledThreadPool(nThreads) { target -> in target()
/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()
DOkHttp3UrlEngineTest.java18 import static java.util.concurrent.Executors.newSingleThreadExecutor;
21 import java.util.concurrent.Executors;
44 dispatchExecutorService = new TestingExecutorService(Executors.newSingleThreadExecutor()); in setUp()
DOkHttp2UrlEngineTest.java18 import static java.util.concurrent.Executors.newSingleThreadExecutor;
23 import java.util.concurrent.Executors;
44 dispatchExecutorService = new TestingExecutorService(Executors.newSingleThreadExecutor()); in setUp()
/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.h72 // run. Executors on different devices may receive the same step_id
146 // A class to help run multiple executors in parallel and wait until
155 // Create an ExecutorBarrier for 'num' different executors.
158 // state. If any of the executors experiences an error, the
168 // Returns a closure that Executors must call when they are done
215 errors::Aborted("Stopping remaining executors.")); in WhenDone()
/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/volley/src/main/java/com/android/volley/
DAsyncRequestQueue.java32 import java.util.concurrent.Executors;
75 * This interface may be used by advanced applications to provide custom executors according to
94 * @param executorFactory Interface to be used to provide custom executors according to the
109 /** Sets the executors and initializes the cache. */
114 // Create blocking / non-blocking executors and set them in the network and stack. in start()
152 /** Shuts down and nullifies both executors */
439 * This class may be used by advanced applications to provide custom executors according to
452 /** Provides a BlockingQueue to be used to create executors. */
564 Thread t = Executors.defaultThreadFactory().newThread(runnable);
/external/libtextclassifier/java/src/com/android/textclassifier/common/
DTextClassifierServiceExecutors.java23 import java.util.concurrent.Executors;
29 * <p>Note because we have two processes, so we may keep two copis of executors in this class.
57 Executors.newFixedThreadPool( in init()
/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/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/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()
/external/jimfs/jimfs/src/test/java/com/google/common/jimfs/
DJimfsAsynchronousFileChannelTest.java46 import java.util.concurrent.Executors;
77 ExecutorService executor = Executors.newSingleThreadExecutor(); in testAsyncChannel()
101 ExecutorService executor = Executors.newSingleThreadExecutor(); in testClosedChannel()
119 ExecutorService executor = Executors.newFixedThreadPool(4); in testAsyncClose_write()
153 ExecutorService executor = Executors.newFixedThreadPool(2); in testAsyncClose_read()
/external/guice/core/test/com/google/inject/internal/
DCycleDetectingLockTest.java12 import java.util.concurrent.Executors;
84 Executors.newSingleThreadExecutor() in testSingletonThreadsRuntimeCircularDependency()
99 Executors.newSingleThreadExecutor() in testSingletonThreadsRuntimeCircularDependency()
140 Executors.newSingleThreadExecutor() in testCycleDetectingLockFactoriesDoNotDeadlock()
157 Executors.newSingleThreadExecutor() in testCycleDetectingLockFactoriesDoNotDeadlock()

12345678910>>...15