| /external/crosvm/base/src/ |
| D | worker_thread.rs | 16 pub struct WorkerThread<T: Send + 'static> { struct
20 impl<T: Send + 'static> WorkerThread<T> { argument
91 impl<T: Send + 'static> Drop for WorkerThread<T> { implementation
|
| /external/rust/android-crates-io/crates/rayon-core/src/ |
| D | registry.rs | 342 pub(super) fn current_thread(&self) -> Option<&WorkerThread> { in current_thread()
489 OP: FnOnce(&WorkerThread, bool) -> R + Send, in in_worker()
510 OP: FnOnce(&WorkerThread, bool) -> R + Send, in in_worker_cold()
534 unsafe fn in_worker_cross<OP, R>(&self, current_thread: &WorkerThread, op: OP) -> R in in_worker_cross()
536 OP: FnOnce(&WorkerThread, bool) -> R + Send, in in_worker_cross()
641 pub(super) struct WorkerThread { struct
659 // This is a bit sketchy, but basically: the WorkerThread is argument
668 impl From<ThreadBuilder> for WorkerThread { implementation
681 impl Drop for WorkerThread { implementation
691 impl WorkerThread { implementation
[all …]
|
| /external/swiftshader/third_party/marl/include/marl/ |
| D | scheduler.h | 60 struct WorkerThread { struct
62 int count = 0;
66 ThreadInitializer initializer;
69 std::shared_ptr<Thread::Affinity::Policy> affinityPolicy;
|
| /external/cronet/stable/base/task/thread_pool/ |
| D | worker_thread_set.h | 18 class WorkerThread; variable
|
| D | pooled_single_thread_task_runner_manager.h | 31 class WorkerThread; variable
|
| D | pooled_single_thread_task_runner_manager.cc | 131 void OnMainEntry(WorkerThread* /* worker */) override { in OnMainEntry() argument
227 void OnMainExit(WorkerThread* /* worker */) override {} in OnMainExit() argument
405 void OnMainExit(WorkerThread* /* worker */) override { in OnMainExit() argument
|
| /external/cronet/tot/base/task/thread_pool/ |
| D | worker_thread_set.h | 18 class WorkerThread; variable
|
| D | pooled_single_thread_task_runner_manager.h | 31 class WorkerThread; variable
|
| D | pooled_single_thread_task_runner_manager.cc | 131 void OnMainEntry(WorkerThread* /* worker */) override { in OnMainEntry() argument
227 void OnMainExit(WorkerThread* /* worker */) override {} in OnMainExit() argument
405 void OnMainExit(WorkerThread* /* worker */) override { in OnMainExit() argument
|
| D | worker_thread.cc | 149 WorkerThread::WorkerThread(ThreadType thread_type_hint, in WorkerThread() function in base::internal::WorkerThread
|
| /external/aws-sdk-java-v2/services/sqs/src/it/java/software/amazon/awssdk/services/sqs/ |
| D | SqsConcurrentPerformanceIntegrationTest.java | 73 private class WorkerThread extends Thread { class in SqsConcurrentPerformanceIntegrationTest
|
| /external/libgav1/src/utils/ |
| D | threadpool.cc | 124 class ThreadPool::WorkerThread : public Allocable { class in libgav1::ThreadPool
160 ThreadPool::WorkerThread::WorkerThread(ThreadPool* pool) : pool_(pool) {} in WorkerThread() function in libgav1::ThreadPool::WorkerThread
|
| /external/rust/android-crates-io/crates/rayon-core/src/scope/ |
| D | mod.rs | 461 fn new(owner: Option<&WorkerThread>, registry: Option<&Arc<Registry>>) -> Self { in new()
557 fn new(owner: Option<&WorkerThread>, registry: Option<&Arc<Registry>>) -> Self { in new()
624 fn new(owner: Option<&WorkerThread>, registry: Option<&Arc<Registry>>) -> Self { in new()
663 fn complete<FUNC, R>(&self, owner: Option<&WorkerThread>, func: FUNC) -> R in complete()
|
| /external/tensorflow/tensorflow/compiler/xla/pjrt/ |
| D | worker_thread.cc | 20 WorkerThread::WorkerThread(tensorflow::Env* env, const std::string& name) { in WorkerThread() function in xla::WorkerThread
|
| /external/webrtc/test/ |
| D | run_loop.cc | 69 RunLoop::WorkerThread::WorkerThread(rtc::SocketServer* ss) in WorkerThread() function in webrtc::test::RunLoop::WorkerThread
|
| /external/grpc-grpc/test/cpp/util/ |
| D | tls_test_utils.cc | 66 void AsyncCertificateVerifier::WorkerThread(void* arg) { in WorkerThread() function in grpc::testing::AsyncCertificateVerifier
|
| /external/python/cpython3/Lib/test/libregrtest/ |
| D | run_workers.py | 108 class WorkerThread(threading.Thread): class
450 def get_running(workers: list[WorkerThread]) -> str | None:
|
| /external/rust/android-crates-io/crates/rayon-core/src/join/ |
| D | mod.rs | 182 worker_thread: &WorkerThread, in join_recover_from_panic()
|
| /external/tensorflow/tensorflow/core/platform/cloud/ |
| D | gcs_dns_cache.cc | 155 void GcsDnsCache::WorkerThread() { in WorkerThread() function in tensorflow::GcsDnsCache
|
| /external/grpc-grpc/src/cpp/thread_manager/ |
| D | thread_manager.cc | 34 ThreadManager::WorkerThread::WorkerThread(ThreadManager* thd_mgr) in WorkerThread() function in grpc::ThreadManager::WorkerThread
|
| /external/rust/android-crates-io/crates/grpcio-sys/grpc/src/cpp/thread_manager/ |
| D | thread_manager.cc | 35 ThreadManager::WorkerThread::WorkerThread(ThreadManager* thd_mgr) in WorkerThread() function in grpc::ThreadManager::WorkerThread
|
| /external/icu/icu4j/main/core/src/test/java/com/ibm/icu/dev/test/charsetdet/ |
| D | TestCharsetDetector.java | 1217 class WorkerThread extends Thread { in TestMultithreaded() class
1218 WorkerThread(int num) { in TestMultithreaded() method in TestCharsetDetector.WorkerThread
|
| /external/icu/android_icu4j/src/main/tests/android/icu/dev/test/charsetdet/ |
| D | TestCharsetDetector.java | 1220 class WorkerThread extends Thread { in TestMultithreaded() class
1221 WorkerThread(int num) { in TestMultithreaded() method in TestCharsetDetector.WorkerThread
|
| /external/crosvm/e2e_tests/tests/ |
| D | console.rs | 133 ) -> WorkerThread<()> { in generate_workthread_to_monitor_fifo()
|
| /external/grpc-grpc/test/core/util/ |
| D | tls_utils.cc | 150 void AsyncExternalVerifier::WorkerThread(void* arg) { in WorkerThread() function in grpc_core::testing::AsyncExternalVerifier
|