| /external/zstd/contrib/pzstd/utils/test/ |
| D | WorkQueueTest.cpp | 37 TEST(WorkQueue, SingleThreaded) { in TEST() argument
64 TEST(WorkQueue, SPSC) { in TEST() argument
92 TEST(WorkQueue, SPMC) { in TEST() argument
115 TEST(WorkQueue, MPMC) { in TEST() argument
150 TEST(WorkQueue, BoundedSizeWorks) { in TEST() argument
163 TEST(WorkQueue, BoundedSizePushAfterFinish) { in TEST() argument
180 TEST(WorkQueue, SetMaxSize) { in TEST() argument
201 TEST(WorkQueue, BoundedSizeMPMC) { in TEST() argument
242 TEST(WorkQueue, FailedPush) { in TEST() argument
|
| /external/rust/android-crates-io/crates/grpcio/src/ |
| D | cq.rs | 143 pub struct WorkQueue { struct
148 unsafe impl Sync for WorkQueue {} argument
149 unsafe impl Send for WorkQueue {} implementation
153 impl WorkQueue { impl
|
| /external/pigweed/pw_work_queue/ |
| D | work_queue_test.cc | 27 TEST(WorkQueue, PingPongOneRequestType) { in TEST() argument
65 TEST(WorkQueue, PingPongTwoRequestTypesWithExtraRequests) { in TEST() argument
|
| /external/pigweed/pw_work_queue/public/pw_work_queue/ |
| D | work_queue.h | 58 WorkQueue(InlineQueue<WorkItem>& queue, size_t queue_capacity) in WorkQueue() function
|
| /external/cronet/tot/base/task/common/ |
| D | task_annotator.h | 23 class WorkQueue; variable
|
| D | task_annotator.cc | 99 PassKey<sequence_manager::internal::WorkQueue>, in SetCurrentTaskForThread()
|
| /external/cronet/stable/base/task/common/ |
| D | task_annotator.h | 23 class WorkQueue; variable
|
| D | task_annotator.cc | 99 PassKey<sequence_manager::internal::WorkQueue>, in SetCurrentTaskForThread()
|
| /external/libchrome/base/task/sequence_manager/ |
| D | work_queue.cc | 13 WorkQueue::WorkQueue(TaskQueueImpl* task_queue, in WorkQueue() function in base::sequence_manager::internal::WorkQueue
|
| D | task_queue_impl.h | 37 class WorkQueue; variable
|
| /external/cronet/stable/base/synchronization/ |
| D | condition_variable_unittest.cc | 68 class WorkQueue : public PlatformThread::Delegate { class
487 WorkQueue::WorkQueue(int thread_count) in WorkQueue() function in base::__anon77b388550111::WorkQueue
|
| /external/cronet/tot/base/synchronization/ |
| D | condition_variable_unittest.cc | 68 class WorkQueue : public PlatformThread::Delegate { class
487 WorkQueue::WorkQueue(int thread_count) in WorkQueue() function in base::__anonb00223710111::WorkQueue
|
| /external/cronet/stable/base/task/sequence_manager/ |
| D | work_queue.cc | 23 WorkQueue::WorkQueue(TaskQueueImpl* task_queue, in WorkQueue() function in base::sequence_manager::internal::WorkQueue
|
| D | task_queue_impl.h | 50 class WorkQueue; variable
|
| /external/cronet/tot/base/task/sequence_manager/ |
| D | work_queue.cc | 23 WorkQueue::WorkQueue(TaskQueueImpl* task_queue, in WorkQueue() function in base::sequence_manager::internal::WorkQueue
|
| D | task_queue_impl.h | 50 class WorkQueue; variable
|
| /external/libchrome/base/synchronization/ |
| D | condition_variable_unittest.cc | 69 class WorkQueue : public PlatformThread::Delegate { class
502 WorkQueue::WorkQueue(int thread_count) in WorkQueue() function in base::__anon574b0cf50111::WorkQueue
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/scheduling/ |
| D | WorkQueue.kt | 42 internal class WorkQueue { class
|
| /external/python/bumble/bumble/ |
| D | utils.py | 243 class WorkQueue: class in AsyncRunner
|