| /external/rust/crates/rayon-core/src/ |
| D | registry.rs | 297 pub(super) fn current_thread(&self) -> Option<&WorkerThread> { in current_thread()
436 OP: FnOnce(&WorkerThread, bool) -> R + Send, in in_worker()
457 OP: FnOnce(&WorkerThread, bool) -> R + Send, in in_worker_cold()
484 unsafe fn in_worker_cross<OP, R>(&self, current_thread: &WorkerThread, op: OP) -> R in in_worker_cross()
486 OP: FnOnce(&WorkerThread, bool) -> R + Send, in in_worker_cross()
594 pub(super) struct WorkerThread { struct
609 // This is a bit sketchy, but basically: the WorkerThread is argument
618 impl Drop for WorkerThread { implementation
628 impl WorkerThread { impl
639 unsafe fn set_current(thread: *const WorkerThread) { in set_current()
[all …]
|
| /external/swiftshader/third_party/marl/include/marl/ |
| D | scheduler.h | 58 struct WorkerThread { struct
60 int count = 0;
64 ThreadInitializer initializer;
67 std::shared_ptr<Thread::Affinity::Policy> affinityPolicy;
|
| /external/libgav1/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/webrtc/rtc_base/ |
| D | task_queue_win.cc | 172 class WorkerThread : public rtc::PlatformThread { class in webrtc::__anonb2f280180111::TaskQueueWin
174 WorkerThread(rtc::ThreadRunFunction func, in WorkerThread() function in webrtc::__anonb2f280180111::TaskQueueWin::WorkerThread
|
| /external/rust/crates/rayon-core/src/scope/ |
| D | mod.rs | 532 unsafe fn complete<FUNC, R>(&self, owner_thread: &WorkerThread, func: FUNC) -> R in complete()
594 unsafe fn steal_till_jobs_complete(&self, owner_thread: &WorkerThread) { in steal_till_jobs_complete()
|
| /external/rust/crates/rayon-core/src/join/ |
| D | mod.rs | 181 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/icu4j/main/tests/core/src/com/ibm/icu/dev/test/rbbi/ |
| D | RBBITest.java | 391 class WorkerThread implements Runnable { in TestBug12873() class
|
| /external/icu/android_icu4j/src/main/tests/android/icu/dev/test/rbbi/ |
| D | RBBITest.java | 394 class WorkerThread implements Runnable { in TestBug12873() class
|
| /external/llvm/lib/Fuzzer/ |
| D | FuzzerDriver.cpp | 199 static void WorkerThread(const std::string &Cmd, std::atomic<int> *Counter, in WorkerThread() function
|
| /external/llvm-project/compiler-rt/lib/sanitizer_common/tests/ |
| D | sanitizer_common_test.cpp | 207 static void *WorkerThread(void *arg) { in WorkerThread() function
|
| /external/llvm-project/compiler-rt/lib/fuzzer/ |
| D | FuzzerFork.cpp | 274 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/rust/crates/libfuzzer-sys/libfuzzer/ |
| D | FuzzerFork.cpp | 274 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/tensorflow/tensorflow/core/kernels/data/experimental/ |
| D | parallel_interleave_dataset_op.cc | 687 void WorkerThread(const std::shared_ptr<IteratorContext>& ctx, in WorkerThread() function in tensorflow::data::experimental::ParallelInterleaveDatasetOp::Dataset::Iterator
|
| /external/stressapptest/src/ |
| D | worker.cc | 228 WorkerThread::WorkerThread() { in WorkerThread() function in WorkerThread
|