| /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
36 [](void* th) { static_cast<ThreadManager::WorkerThread*>(th)->Run(); }, in WorkerThread()
41 void ThreadManager::WorkerThread::Run() { in Run()
46 ThreadManager::WorkerThread::~WorkerThread() { in ~WorkerThread()
96 void ThreadManager::MarkAsCompleted(WorkerThread* thd) { in MarkAsCompleted()
115 std::list<WorkerThread*> completed_threads; in CleanupCompletedThreads()
142 new WorkerThread(this); in Initialize()
180 new WorkerThread(this); in MainWorkLoop()
|
| D | thread_manager.h | 121 class WorkerThread {
123 WorkerThread(ThreadManager* thd_mgr);
124 ~WorkerThread();
138 void MarkAsCompleted(WorkerThread* thd);
173 std::list<WorkerThread*> completed_threads_;
|
| /external/v8/src/libplatform/ |
| D | worker-thread.cc | 13 WorkerThread::WorkerThread(TaskQueue* queue) in WorkerThread() function in v8::platform::WorkerThread
19 WorkerThread::~WorkerThread() { in ~WorkerThread()
24 void WorkerThread::Run() { in Run()
|
| D | worker-thread.h | 21 class V8_PLATFORM_EXPORT WorkerThread : public NON_EXPORTED_BASE(base::Thread) { in NON_EXPORTED_BASE()
23 explicit WorkerThread(TaskQueue* queue); in NON_EXPORTED_BASE()
24 virtual ~WorkerThread(); in NON_EXPORTED_BASE()
34 DISALLOW_COPY_AND_ASSIGN(WorkerThread); in NON_EXPORTED_BASE()
|
| D | default-worker-threads-task-runner.h | 15 class WorkerThread; variable
40 std::vector<std::unique_ptr<WorkerThread>> thread_pool_; in NON_EXPORTED_BASE()
|
| D | default-worker-threads-task-runner.cc | 16 thread_pool_.push_back(base::make_unique<WorkerThread>(&queue_)); in DefaultWorkerThreadsTaskRunner()
|
| D | default-platform.h | 27 class WorkerThread; variable
|
| /external/stressapptest/src/ |
| D | worker.h | 202 class WorkerThread {
210 WorkerThread();
211 virtual ~WorkerThread();
404 DISALLOW_COPY_AND_ASSIGN(WorkerThread);
408 class FileThread : public WorkerThread {
491 class NetworkThread : public WorkerThread {
557 class CopyThread : public WorkerThread {
570 class InvertThread : public WorkerThread {
585 class FillThread : public WorkerThread {
602 class CheckThread : public WorkerThread {
[all …]
|
| D | worker.cc | 124 WorkerThread *worker = static_cast<WorkerThread*>(ptr); in ThreadSpawnerGeneric()
228 WorkerThread::WorkerThread() { in WorkerThread() function in WorkerThread
239 WorkerThread::~WorkerThread() {} in ~WorkerThread()
280 void WorkerThread::InitThread(int thread_num_init, in InitThread()
302 bool WorkerThread::InitPriority() { in InitPriority()
334 int WorkerThread::SpawnThread() { in SpawnThread()
352 bool WorkerThread::KillThread() { in KillThread()
357 bool WorkerThread::JoinThread() { in JoinThread()
370 void WorkerThread::StartRoutine() { in StartRoutine()
380 bool WorkerThread::Work() { in Work()
[all …]
|
| D | sat.h | 278 typedef vector<WorkerThread*> WorkerVector;
|
| D | sat.cc | 1266 thread->SetPriority(WorkerThread::High); in InitializeThreads()
|
| /external/tensorflow/tensorflow/lite/models/smartreply/demo/app/src/main/java/com/example/android/smartreply/ |
| D | SmartReplyClient.java | 21 import android.support.annotation.WorkerThread;
53 @WorkerThread
70 @WorkerThread
79 @WorkerThread
|
| /external/tensorflow/tensorflow/core/platform/cloud/ |
| D | gcs_dns_cache.cc | 75 [this]() { return WorkerThread(); })); in AnnotateRequest()
153 void GcsDnsCache::WorkerThread() { in WorkerThread() function in tensorflow::GcsDnsCache
|
| D | gcs_dns_cache.h | 57 void WorkerThread();
|
| /external/compiler-rt/lib/sanitizer_common/tests/ |
| D | sanitizer_common_test.cc | 152 static void *WorkerThread(void *arg) { in WorkerThread() function
165 PTHREAD_CREATE(&t, 0, WorkerThread, 0); in TEST()
|
| /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
1239 threads[i] = new WorkerThread(i); in TestMultithreaded()
|
| /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
1242 threads[i] = new WorkerThread(i); in TestMultithreaded()
|
| /external/llvm/lib/Fuzzer/ |
| D | FuzzerDriver.cpp | 199 static void WorkerThread(const std::string &Cmd, std::atomic<int> *Counter, in WorkerThread() function
232 V.push_back(std::thread(WorkerThread, Cmd, &Counter, NumJobs, &HasErrors)); in RunInMultipleProcesses()
|
| /external/v8/src/ |
| D | d8.h | 254 class WorkerThread : public base::Thread {
256 explicit WorkerThread(Worker* worker) in WorkerThread() function
|
| D | d8.cc | 2622 thread_ = new WorkerThread(this); in StartExecuteInThread()
|
| /external/icu/icu4j/main/tests/core/src/com/ibm/icu/dev/test/rbbi/ |
| D | RBBITest.java | 389 class WorkerThread implements Runnable { in TestBug12873() class
411 threads.add(new Thread(new WorkerThread())); in TestBug12873()
|
| /external/icu/android_icu4j/src/main/tests/android/icu/dev/test/rbbi/ |
| D | RBBITest.java | 392 class WorkerThread implements Runnable { in TestBug12873() class
414 threads.add(new Thread(new WorkerThread())); in TestBug12873()
|
| /external/tensorflow/tensorflow/core/kernels/data/experimental/ |
| D | parallel_interleave_dataset_op.cc | 498 [this, new_ctx, i]() { WorkerThread(new_ctx, i); })); in RestoreInternal()
597 [this, new_ctx, i]() { WorkerThread(new_ctx, i); })); in EnsureWorkerThreadsStarted()
612 void WorkerThread(const std::shared_ptr<IteratorContext>& ctx, in WorkerThread() function in tensorflow::data::__anonc2a99ed10111::ParallelInterleaveDatasetOp::Dataset::Iterator
|
| D | numa_map_and_batch_dataset_op.cc | 931 [this, new_ctx, i, j]() { WorkerThread(new_ctx, i, j); })); in EnsureBackgroundThreadsStarted()
1024 void WorkerThread(std::shared_ptr<IteratorContext> ctx, in WorkerThread() function in tensorflow::data::__anon9271f8770111::NumaMapAndBatchDatasetOp::Dataset::Iterator
|