| /external/crosvm/base/src/ |
| D | worker_thread.rs | 16 pub struct WorkerThread<T: Send + 'static> { struct
20 impl<T: Send + 'static> WorkerThread<T> { impl
91 impl<T: Send + 'static> Drop for WorkerThread<T> { implementation
|
| /external/rust/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 …]
|
| D | latch.rs | 390 pub(super) fn wait(&self, owner: Option<&WorkerThread>) { in wait()
|
| /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/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 | 122 class ThreadPool::WorkerThread : public Allocable { class in libgav1::ThreadPool
158 ThreadPool::WorkerThread::WorkerThread(ThreadPool* pool) : pool_(pool) {} in WorkerThread() function in libgav1::ThreadPool::WorkerThread
|
| /external/rust/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/mesa3d/src/gfxstream/host/compressedTextureFormats/ |
| D | AstcCpuDecompressorImpl.cpp | 158 class WorkerThread { class
160 explicit WorkerThread() : mThread(&WorkerThread::main, this) {} in WorkerThread() function in gfxstream::vk::__anon6660b5b20111::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/cronet/base/task/thread_pool/ |
| D | pooled_single_thread_task_runner_manager.cc | 124 void OnMainEntry(WorkerThread* /* worker */) override { in OnMainEntry() argument
216 void OnMainExit(WorkerThread* /* worker */) override {} in OnMainExit() argument
380 void OnMainExit(WorkerThread* /* worker */) override { in OnMainExit() argument
|
| D | worker_thread.cc | 134 WorkerThread::WorkerThread(ThreadType thread_type_hint, in WorkerThread() function in base::internal::WorkerThread
|
| /external/rust/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/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/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/grpc-grpc/test/core/util/ |
| D | tls_utils.cc | 150 void AsyncExternalVerifier::WorkerThread(void* arg) { in WorkerThread() function in grpc_core::testing::AsyncExternalVerifier
|
| /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/core/src/test/java/com/ibm/icu/dev/test/rbbi/ |
| D | RBBITest.java | 395 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/rust/crates/libfuzzer-sys/libfuzzer/ |
| D | FuzzerFork.cpp | 303 void WorkerThread(JobQueue *FuzzQ, JobQueue *MergeQ) { in WorkerThread() function
|