| /external/libgav1/libgav1/src/utils/ |
| D | threadpool.cc | 74 std::unique_ptr<WorkerThread*[]> threads(new (std::nothrow) in Create()
75 WorkerThread*[num_threads]); in Create()
86 std::unique_ptr<WorkerThread*[]> threads, in ThreadPool()
117 class ThreadPool::WorkerThread : public Allocable { class in libgav1::ThreadPool
120 explicit WorkerThread(ThreadPool* pool);
123 WorkerThread(const WorkerThread&) = delete;
124 WorkerThread& operator=(const WorkerThread&) = delete;
128 ~WorkerThread() = default;
153 ThreadPool::WorkerThread::WorkerThread(ThreadPool* pool) : pool_(pool) {} in WorkerThread() function in libgav1::ThreadPool::WorkerThread
157 bool ThreadPool::WorkerThread::Start() { in Start()
[all …]
|
| D | threadpool.h | 98 class WorkerThread;
102 ThreadPool(const char name_prefix[], std::unique_ptr<WorkerThread*[]> threads,
153 const std::unique_ptr<WorkerThread*[]> threads_;
|
| /external/tensorflow/tensorflow/compiler/xla/python/ |
| D | worker_thread.cc | 20 WorkerThread::WorkerThread(tensorflow::Env* env, const std::string& name) { in WorkerThread() function in xla::WorkerThread
25 WorkerThread::~WorkerThread() { in ~WorkerThread()
30 void WorkerThread::Schedule(std::function<void()> fn) { in Schedule()
36 bool WorkerThread::WorkAvailable() { return !work_queue_.empty(); } in WorkAvailable()
38 void WorkerThread::WorkLoop() { in WorkLoop()
43 mu_.Await(absl::Condition(this, &WorkerThread::WorkAvailable)); in WorkLoop()
|
| D | worker_thread.h | 31 class WorkerThread {
34 WorkerThread(tensorflow::Env* env, const std::string& name);
37 ~WorkerThread();
|
| D | local_device_state.h | 79 WorkerThread* execute_thread() const { return execute_thread_.get(); } in execute_thread()
145 std::unique_ptr<WorkerThread> execute_thread_;
151 std::unique_ptr<WorkerThread> callback_thread_;
|
| D | local_device_state.cc | 57 execute_thread_ = absl::make_unique<WorkerThread>(tensorflow::Env::Default(), in LocalDeviceState()
59 callback_thread_ = absl::make_unique<WorkerThread>(tensorflow::Env::Default(), in LocalDeviceState()
|
| /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/exoplayer/tree/library/core/src/main/java/com/google/android/exoplayer2/upstream/cache/ |
| D | Cache.java | 19 import androidx.annotation.WorkerThread;
107 @WorkerThread
177 @WorkerThread
191 @WorkerThread
208 @WorkerThread
221 @WorkerThread
240 @WorkerThread
275 @WorkerThread
|
| D | CacheFileMetadataIndex.java | 22 import androidx.annotation.WorkerThread;
74 @WorkerThread
108 @WorkerThread
144 @WorkerThread
170 @WorkerThread
193 @WorkerThread
212 @WorkerThread
|
| D | CacheUtil.java | 21 import androidx.annotation.WorkerThread;
118 @WorkerThread
155 @WorkerThread
326 @WorkerThread
340 @WorkerThread
|
| D | CachedContentIndex.java | 28 import androidx.annotation.WorkerThread;
114 @WorkerThread
186 @WorkerThread
213 @WorkerThread
|
| /external/v8/src/libplatform/ |
| D | worker-thread.cc | 13 WorkerThread::WorkerThread(TaskQueue* queue) in WorkerThread() function in v8::platform::WorkerThread
18 WorkerThread::~WorkerThread() { in ~WorkerThread()
22 void WorkerThread::Run() { in Run()
|
| D | default-worker-threads-task-runner.cc | 16 thread_pool_.push_back(std::make_unique<WorkerThread>(this)); in DefaultWorkerThreadsTaskRunner()
62 DefaultWorkerThreadsTaskRunner::WorkerThread::WorkerThread( in WorkerThread() function in v8::platform::DefaultWorkerThreadsTaskRunner::WorkerThread
69 DefaultWorkerThreadsTaskRunner::WorkerThread::~WorkerThread() { Join(); } in ~WorkerThread()
71 void DefaultWorkerThreadsTaskRunner::WorkerThread::Run() { in Run()
|
| D | default-worker-threads-task-runner.h | 45 class WorkerThread : public base::Thread { in NON_EXPORTED_BASE()
47 explicit WorkerThread(DefaultWorkerThreadsTaskRunner* runner); in NON_EXPORTED_BASE()
48 ~WorkerThread() override; in NON_EXPORTED_BASE()
56 DISALLOW_COPY_AND_ASSIGN(WorkerThread); in NON_EXPORTED_BASE()
66 std::vector<std::unique_ptr<WorkerThread>> thread_pool_; in NON_EXPORTED_BASE()
|
| 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 ~WorkerThread() override; in NON_EXPORTED_BASE()
32 DISALLOW_COPY_AND_ASSIGN(WorkerThread); in NON_EXPORTED_BASE()
|
| D | default-platform.h | 24 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 …]
|
| /external/exoplayer/tree/library/core/src/main/java/com/google/android/exoplayer2/offline/ |
| D | DownloadIndex.java | 19 import androidx.annotation.WorkerThread;
23 @WorkerThread
|
| D | WritableDownloadIndex.java | 18 import androidx.annotation.WorkerThread;
22 @WorkerThread
|
| D | ActionFileUpgradeUtil.java | 21 import androidx.annotation.WorkerThread;
61 @WorkerThread
|
| /external/tensorflow/tensorflow/core/platform/cloud/ |
| D | gcs_dns_cache.cc | 77 [this]() { return WorkerThread(); })); in AnnotateRequest()
155 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()
|