| /external/crosvm/base/src/ |
| D | worker_thread.rs | 15 pub struct WorkerThread<T: Send + 'static> { struct
19 impl<T: Send + 'static> WorkerThread<T> { argument
77 impl<T: Send + 'static> Drop for WorkerThread<T> { implementation
|
| /external/rust/crates/rayon-core/src/ |
| D | registry.rs | 346 pub(super) fn current_thread(&self) -> Option<&WorkerThread> { in current_thread()
508 OP: FnOnce(&WorkerThread, bool) -> R + Send, in in_worker()
529 OP: FnOnce(&WorkerThread, bool) -> R + Send, in in_worker_cold()
556 unsafe fn in_worker_cross<OP, R>(&self, current_thread: &WorkerThread, op: OP) -> R in in_worker_cross()
558 OP: FnOnce(&WorkerThread, bool) -> R + Send, in in_worker_cross()
666 pub(super) struct WorkerThread { struct
684 // This is a bit sketchy, but basically: the WorkerThread is argument
693 impl From<ThreadBuilder> for WorkerThread { implementation
706 impl Drop for WorkerThread { implementation
716 impl WorkerThread { impl
[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/base/task/thread_pool/ |
| D | worker_thread_set.h | 17 class WorkerThread; variable
|
| D | pooled_single_thread_task_runner_manager.h | 31 class WorkerThread; variable
|
| D | pooled_single_thread_task_runner_manager.cc | 123 void OnMainEntry(WorkerThread* /* worker */) override { in OnMainEntry() argument
187 void OnMainExit(WorkerThread* /* worker */) override {} in OnMainExit() argument
348 void OnMainExit(WorkerThread* /* worker */) override { in OnMainExit() argument
|
| D | worker_thread.cc | 137 WorkerThread::WorkerThread(ThreadType thread_type_hint, in WorkerThread() function in base::internal::WorkerThread
|
| /external/rust/crates/rayon-core/src/scope/ |
| D | mod.rs | 481 fn new(owner: Option<&WorkerThread>, registry: Option<&Arc<Registry>>) -> Self { in new()
577 fn new(owner: Option<&WorkerThread>, registry: Option<&Arc<Registry>>) -> Self { in new()
644 fn new(owner: Option<&WorkerThread>, registry: Option<&Arc<Registry>>) -> Self { in new()
687 fn complete<FUNC, R>(&self, owner: Option<&WorkerThread>, func: FUNC) -> R in complete()
782 pub(super) fn wait(&self, owner: Option<&WorkerThread>) { in wait()
|
| /external/libgav1/src/utils/ |
| D | threadpool.cc | 121 class ThreadPool::WorkerThread : public Allocable { class in libgav1::ThreadPool
157 ThreadPool::WorkerThread::WorkerThread(ThreadPool* pool) : pool_(pool) {} in WorkerThread() function in libgav1::ThreadPool::WorkerThread
|
| /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/rust/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 | 30 ThreadManager::WorkerThread::WorkerThread(ThreadManager* thd_mgr) in WorkerThread() function in grpc::ThreadManager::WorkerThread
|
| /external/rust/crates/grpcio-sys/grpc/src/cpp/thread_manager/ |
| D | thread_manager.cc | 29 ThreadManager::WorkerThread::WorkerThread(ThreadManager* thd_mgr) in WorkerThread() function in grpc::ThreadManager::WorkerThread
|
| /external/icu/icu4j/main/tests/core/src/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/compiler-rt/lib/sanitizer_common/tests/ |
| D | sanitizer_common_test.cc | 152 static void *WorkerThread(void *arg) { in WorkerThread() function
|
| /external/icu/android_icu4j/src/main/tests/android/icu/dev/test/rbbi/ |
| D | RBBITest.java | 398 class WorkerThread implements Runnable { in TestBug12873() class
|
| /external/icu/icu4j/main/tests/core/src/com/ibm/icu/dev/test/rbbi/ |
| D | RBBITest.java | 395 class WorkerThread implements Runnable { in TestBug12873() class
|
| /external/crosvm/devices/src/virtio/vhost/user/vmm/ |
| D | handler.rs | 264 ) -> Result<WorkerThread<()>> { in activate()
|
| /external/llvm/lib/Fuzzer/ |
| D | FuzzerDriver.cpp | 199 static void WorkerThread(const std::string &Cmd, std::atomic<int> *Counter, in WorkerThread() function
|
| /external/rust/crates/libfuzzer-sys/libfuzzer/ |
| D | FuzzerFork.cpp | 303 void WorkerThread(JobQueue *FuzzQ, JobQueue *MergeQ) { in WorkerThread() function
|
| D | FuzzerDriver.cpp | 230 static void WorkerThread(const Command &BaseCmd, std::atomic<unsigned> *Counter, in WorkerThread() function
|
| /external/cronet/base/threading/ |
| D | thread_restrictions.h | 184 class WorkerThread; variable
|