| /external/aws-sdk-java-v2/test/stability-tests/src/it/java/software/amazon/awssdk/stability/tests/utils/ |
| D | StabilityTestsRunnerTest.java | 25 import java.util.concurrent.Executors;
38 private static ExecutorService executors; field in StabilityTestsRunnerTest
42 executors = Executors.newFixedThreadPool(10); in setUp()
47 executors.shutdown(); in tearDown()
54 … "hello world " + i), executors)) in testUsingFutureFactory()
68 executors)); in testUsingFutures() local
82 }, executors)); in unexpectedExceptionThrown_shouldFailTests()
84 executors)); in unexpectedExceptionThrown_shouldFailTests() local
102 }, executors)); in expectedExceptionThrownExceedsThreshold_shouldFailTests()
105 executors)); in expectedExceptionThrownExceedsThreshold_shouldFailTests() local
[all …]
|
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | executor.cc | 57 Executor* executors[static_cast<size_t>(ExecutorType::NUM_EXECUTORS)]; variable
60 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Enqueue( in default_enqueue_short()
65 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Enqueue( in default_enqueue_long()
70 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Enqueue( in resolver_enqueue_short()
75 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Enqueue( in resolver_enqueue_long()
373 if (executors[static_cast<size_t>(ExecutorType::DEFAULT)] != nullptr) { in InitAll()
374 GPR_ASSERT(executors[static_cast<size_t>(ExecutorType::RESOLVER)] != in InitAll()
379 executors[static_cast<size_t>(ExecutorType::DEFAULT)] = in InitAll()
381 executors[static_cast<size_t>(ExecutorType::RESOLVER)] = in InitAll()
384 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Init(); in InitAll()
[all …]
|
| D | executor.h | 75 // 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/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/ |
| D | executor.cc | 57 Executor* executors[static_cast<size_t>(ExecutorType::NUM_EXECUTORS)]; variable
60 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Enqueue( in default_enqueue_short()
65 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Enqueue( in default_enqueue_long()
70 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Enqueue( in resolver_enqueue_short()
75 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Enqueue( in resolver_enqueue_long()
373 if (executors[static_cast<size_t>(ExecutorType::DEFAULT)] != nullptr) { in InitAll()
374 GPR_ASSERT(executors[static_cast<size_t>(ExecutorType::RESOLVER)] != in InitAll()
379 executors[static_cast<size_t>(ExecutorType::DEFAULT)] = in InitAll()
381 executors[static_cast<size_t>(ExecutorType::RESOLVER)] = in InitAll()
384 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Init(); in InitAll()
[all …]
|
| D | executor.h | 75 // 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/okio/okio-testing-support/src/jvmMain/kotlin/okio/ |
| D | TestingExecutors.kt | 19 import java.util.concurrent.Executors
27 Executors.newScheduledThreadPool(corePoolSize, newVirtualThreadFactory()) in newScheduledExecutorService()
29 Executors.newScheduledThreadPool(corePoolSize)
33 Executors.newScheduledThreadPool(corePoolSize, newVirtualThreadFactory()) in newExecutorService()
35 Executors.newScheduledThreadPool(corePoolSize)
44 …return Executors::class.java.getMethod("newVirtualThreadPerTaskExecutor").invoke(null) as Executor… in newVirtualThreadPerTaskExecutor()
|
| /external/sdv/vsomeip/third_party/boost/thread/include/boost/thread/executors/detail/ |
| D | scheduled_executor_base.hpp | 12 #include <boost/thread/executors/detail/priority_executor_base.hpp>
13 #include <boost/thread/executors/work.hpp>
23 namespace executors namespace
28 …cutor_base : public priority_executor_base<concurrent::sync_timed_queue<executors::work_pq, Clock …
31 typedef executors::work_pq work;
61 } //end executors namespace
|
| D | priority_executor_base.hpp | 15 #include <boost/thread/executors/work.hpp>
19 namespace executors namespace
28 typedef executors::work_pq work;
81 } //end executors namespace
|
| /external/sdv/vsomeip/third_party/boost/asio/doc/ |
| D | std_executors.qbk | 8 [section:std_executors Proposed Standard Executors]
10 Boost.Asio provides a complete implementation of the proposed standard executors, as
14 Just as with executors under the Networking TS model, a standard executor
23 boost_asio.reference.strand `strand`] executors meet the requirements for the
24 proposed standard executors. For compatibility, these classes also meet the
25 requirements for the Networking TS model of executors.
38 proposed standard executors, and with Networking TS executors. Boost.Asio's
43 Support for the existing Networking TS model of executors can be disabled
|
| /external/sdv/vsomeip/third_party/boost/thread/include/boost/thread/executors/ |
| D | scheduler.hpp | 12 #include <boost/thread/executors/detail/scheduled_executor_base.hpp>
27 namespace executors namespace
268 using executors::resubmitter;
269 using executors::resubmit;
270 using executors::resubmit_at_executor;
271 using executors::scheduler_executor_wrapper;
272 using executors::at_executor;
273 using executors::scheduler;
|
| D | scheduled_thread_pool.hpp | 14 #include <boost/thread/executors/detail/scheduled_executor_base.hpp>
18 namespace executors namespace
46 } //end executors namespace
48 using executors::scheduled_thread_pool;
|
| D | scheduling_adaptor.hpp | 13 #include <boost/thread/executors/detail/scheduled_executor_base.hpp>
22 namespace executors namespace
54 } //end executors
56 using executors::scheduling_adaptor;
|
| D | generic_executor_ref.hpp | 15 #include <boost/thread/executors/executor.hpp>
23 namespace executors namespace
32 typedef executors::work work;
99 typedef executors::work work;
208 using executors::executor_ref;
209 using executors::generic_executor_ref;
|
| /external/sdv/vsomeip/third_party/boost/asio/include/boost/asio/impl/ |
| D | compose.hpp | 459 template <typename Signature, typename Executors>
463 typedef typename composed_io_executors<Executors>::head_type executor_type;
466 explicit initiate_composed_op(int, BOOST_ASIO_MOVE_ARG(T) executors) in initiate_composed_op() argument
467 : executors_(BOOST_ASIO_MOVE_CAST(T)(executors)) in initiate_composed_op()
480 composed_op<typename decay<Impl>::type, composed_work<Executors>, in operator ()()
483 composed_work<Executors>(executors_), in operator ()()
488 composed_io_executors<Executors> executors_;
491 template <typename Signature, typename Executors>
492 inline initiate_composed_op<Signature, Executors> make_initiate_composed_op( in make_initiate_composed_op()
493 BOOST_ASIO_MOVE_ARG(composed_io_executors<Executors>) executors) in make_initiate_composed_op()
[all …]
|
| /external/sdv/vsomeip/third_party/boost/thread/example/ |
| D | generic_executor_ref.cpp | 18 #include <boost/thread/executors/basic_thread_pool.hpp>
19 #include <boost/thread/executors/loop_executor.hpp>
20 #include <boost/thread/executors/serial_executor.hpp>
21 #include <boost/thread/executors/inline_executor.hpp>
22 #include <boost/thread/executors/thread_executor.hpp>
23 #include <boost/thread/executors/executor.hpp>
24 #include <boost/thread/executors/executor_adaptor.hpp>
|
| D | executor.cpp | 19 #include <boost/thread/executors/basic_thread_pool.hpp>
20 #include <boost/thread/executors/loop_executor.hpp>
21 #include <boost/thread/executors/serial_executor.hpp>
22 #include <boost/thread/executors/inline_executor.hpp>
23 #include <boost/thread/executors/thread_executor.hpp>
24 #include <boost/thread/executors/executor.hpp>
25 #include <boost/thread/executors/executor_adaptor.hpp>
|
| /external/sdv/vsomeip/third_party/boost/thread/doc/ |
| D | async_executors.qbk | 9 [section:executors Executors and Schedulers -- EXPERIMENTAL]
13 …://www.open-std.org/JTC1/SC22/WG21/docs/papers/2013/n3785.pdf [*N3785 - Executors and Schedulers r…
15 Executors are objects that can execute units of work packaged as function objects. Boost.Thread dif…
22 …executors when necessary, switch from one executor to another to control execution policy, and use…
28 # Thread-spawning executors, in which each work always executes in a new thread.
32 # Mutual exclusion executors
33 …# Serial executors, which guarantee all work to be executed such that no two works will execute co…
37 # Inline executors, which execute inline to the thread which calls submit(). This has no queuing an…
39 …executors (or others) be included in this library. There are use cases for these and many other ex…
55 #include <boost/thread/executors/basic_thread_pool.hpp>
[all …]
|
| /external/aws-sdk-java-v2/utils/src/test/java/software/amazon/awssdk/utils/ |
| D | CompletableFutureUtilsTest.java | 26 import java.util.concurrent.Executors;
32 private static ExecutorService executors; field in CompletableFutureUtilsTest
36 executors = Executors.newFixedThreadPool(2); in setup()
41 executors.shutdown(); in tearDown()
68 …letableFuture<String> returnedFuture = CompletableFutureUtils.forwardResultTo(src, dst, executors); in forwardResultTo_srcCompletesSuccessfully_shouldCompleteDstFuture()
81 CompletableFutureUtils.forwardResultTo(src, dst, executors); in forwardResultTo_srcCompletesExceptionally_shouldCompleteDstFuture()
|
| /external/autotest/server/cros/tradefed/tradefed_utils_unittest_data/ |
| D | GtsPlacementTestCases.txt | 52 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 …]
|
| /external/tensorflow/tensorflow/compiler/xla/stream_executor/ |
| D | executor_cache.h | 47 // 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/sdv/vsomeip/third_party/boost/thread/test/ |
| D | test_scheduling_adaptor.cpp | 17 #include <boost/thread/executors/executor.hpp>
18 #include <boost/thread/executors/basic_thread_pool.hpp>
19 #include <boost/thread/executors/scheduling_adaptor.hpp>
27 typedef boost::executors::basic_thread_pool thread_pool;
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | WithTimeoutOrNullThreadDispatchTest.kt | 9 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()
|
| D | WithTimeoutThreadDispatchTest.kt | 9 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()
|
| /external/downloader/src/test/java/com/google/android/downloader/ |
| D | TestExecutorRule.java | 27 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/robolectric/robolectric/src/test/java/org/robolectric/shadows/ |
| D | ShadowWifiManagerTest.java | 50 import java.util.concurrent.Executors;
928 Executors.newSingleThreadExecutor(), in setExternalPnoScanRequest_nullCallback_throwsIllegalArgumentException()
954 Executors.newSingleThreadExecutor(), in setExternalPnoScanRequest_nullSsidList_throwsIllegalStateException()
967 Executors.newSingleThreadExecutor(), in setExternalPnoScanRequest_emptySsidList_throwsIllegalStateException()
983 Executors.newSingleThreadExecutor(), in setExternalPnoScanRequest_moreThan2Ssids_throwsIllegalArgumentException()
998 Executors.newSingleThreadExecutor(), in setExternalPnoScanRequest_moreThan10Frequencies_throwsIllegalArgumentException()
1010 Executors.newSingleThreadExecutor(), in setExternalPnoScanRequest_validRequest_successCallbackInvoked()
1026 Executors.newSingleThreadExecutor(), in setExternalPnoScanRequest_outstandingRequest_failureCallbackInvokedWithAlreadyRegisteredStatus()
1032 Executors.newSingleThreadExecutor(), in setExternalPnoScanRequest_outstandingRequest_failureCallbackInvokedWithAlreadyRegisteredStatus()
1048 Executors.newSingleThreadExecutor(), in setExternalPnoScanRequest_differentUid_failureCallbackInvokedWithBusyStatus()
[all …]
|