| /external/libgav1/src/utils/ |
| D | threadpool.cc | 78 std::unique_ptr<WorkerThread*[]> threads(new (std::nothrow) in Create()
79 WorkerThread*[num_threads]); in Create()
90 std::unique_ptr<WorkerThread*[]> threads, in ThreadPool()
121 class ThreadPool::WorkerThread : public Allocable { class in libgav1::ThreadPool
124 explicit WorkerThread(ThreadPool* pool);
127 WorkerThread(const WorkerThread&) = delete;
128 WorkerThread& operator=(const WorkerThread&) = delete;
132 ~WorkerThread() = default;
157 ThreadPool::WorkerThread::WorkerThread(ThreadPool* pool) : pool_(pool) {} in WorkerThread() function in libgav1::ThreadPool::WorkerThread
161 bool ThreadPool::WorkerThread::Start() { in Start()
[all …]
|
| /external/cronet/base/task/thread_pool/ |
| D | worker_thread.cc | 90 constexpr TimeDelta WorkerThread::Delegate::kPurgeThreadCacheIdleDelay;
92 void WorkerThread::Delegate::WaitForWork(WaitableEvent* wake_up_event) { in WaitForWork()
137 WorkerThread::WorkerThread(ThreadType thread_type_hint, in WorkerThread() function in base::internal::WorkerThread
157 bool WorkerThread::Start( in Start()
204 void WorkerThread::WakeUp() { in WakeUp()
218 void WorkerThread::JoinForTesting() { in JoinForTesting()
239 bool WorkerThread::ThreadAliveForTesting() const { in ThreadAliveForTesting()
244 WorkerThread::~WorkerThread() { in ~WorkerThread()
254 void WorkerThread::Cleanup() { in Cleanup()
260 void WorkerThread::MaybeUpdateThreadType() { in MaybeUpdateThreadType()
[all …]
|
| D | worker_thread.h | 42 class BASE_EXPORT WorkerThread : public RefCountedThreadSafe<WorkerThread>,
69 virtual void OnMainEntry(WorkerThread* worker) = 0;
72 virtual RegisteredTaskSource GetWork(WorkerThread* worker) = 0;
94 virtual void OnMainExit(WorkerThread* worker) {} in OnMainExit()
113 WorkerThread(ThreadType thread_type_hint,
119 WorkerThread(const WorkerThread&) = delete;
120 WorkerThread& operator=(const WorkerThread&) = delete;
140 WorkerThread::Delegate* delegate() { return delegate_.get(); } in delegate()
180 friend class RefCountedThreadSafe<WorkerThread>;
183 ~WorkerThread() override;
[all …]
|
| D | worker_thread_set.h | 17 class WorkerThread; variable
27 bool operator()(const WorkerThread* a, const WorkerThread* b) const;
39 void Insert(WorkerThread* worker);
44 WorkerThread* Take();
47 WorkerThread* Peek() const;
50 bool Contains(const WorkerThread* worker) const;
54 void Remove(const WorkerThread* worker);
63 std::set<WorkerThread*, Compare> set_;
|
| D | worker_thread_set.cc | 14 bool WorkerThreadSet::Compare::operator()(const WorkerThread* a, in operator ()()
15 const WorkerThread* b) const { in operator ()()
23 void WorkerThreadSet::Insert(WorkerThread* worker) { in Insert()
33 WorkerThread* WorkerThreadSet::Take() { in Take()
36 WorkerThread* const worker = *set_.begin(); in Take()
43 WorkerThread* WorkerThreadSet::Peek() const { in Peek()
49 bool WorkerThreadSet::Contains(const WorkerThread* worker) const { in Contains()
50 return set_.count(const_cast<WorkerThread*>(worker)) > 0; in Contains()
53 void WorkerThreadSet::Remove(const WorkerThread* worker) { in Remove()
56 auto it = set_.find(const_cast<WorkerThread*>(worker)); in Remove()
|
| D | pooled_single_thread_task_runner_manager.cc | 103 class WorkerThreadDelegate : public WorkerThread::Delegate {
106 WorkerThread::ThreadLabel thread_label, in WorkerThreadDelegate()
114 void set_worker(WorkerThread* worker) { in set_worker()
119 WorkerThread::ThreadLabel GetThreadLabel() const final { in GetThreadLabel()
123 void OnMainEntry(WorkerThread* /* worker */) override { in OnMainEntry() argument
128 RegisteredTaskSource GetWork(WorkerThread* worker) override { in GetWork()
187 void OnMainExit(WorkerThread* /* worker */) override {} in OnMainExit() argument
208 RegisteredTaskSource GetWorkLockRequired(WorkerThread* worker) in GetWorkLockRequired()
252 const WorkerThread::ThreadLabel thread_label_;
257 raw_ptr<WorkerThread> worker_ = nullptr;
[all …]
|
| D | thread_group_impl.cc | 82 bool ContainsWorker(const std::vector<scoped_refptr<WorkerThread>>& workers, in ContainsWorker()
83 const WorkerThread* worker) { in ContainsWorker()
85 ranges::find_if(workers, [worker](const scoped_refptr<WorkerThread>& i) { in ContainsWorker()
104 void ScheduleWakeUp(scoped_refptr<WorkerThread> worker) { in ScheduleWakeUp()
108 void ScheduleStart(scoped_refptr<WorkerThread> worker) { in ScheduleStart()
134 void AddWorker(scoped_refptr<WorkerThread> worker) { in AddWorker()
147 for (scoped_refptr<WorkerThread> worker : additional_workers_) in ForEachWorker()
164 scoped_refptr<WorkerThread> first_worker_;
165 std::vector<scoped_refptr<WorkerThread>> additional_workers_;
173 [](WorkerThread* worker) { worker->WakeUp(); }); in FlushImpl()
[all …]
|
| D | worker_thread_set_unittest.cc | 21 class MockWorkerThreadDelegate : public WorkerThread::Delegate {
23 WorkerThread::ThreadLabel GetThreadLabel() const override { in GetThreadLabel()
24 return WorkerThread::ThreadLabel::DEDICATED; in GetThreadLabel()
26 void OnMainEntry(WorkerThread* worker) override {} in OnMainEntry()
27 RegisteredTaskSource GetWork(WorkerThread* worker) override { in GetWork()
39 worker_a_ = MakeRefCounted<WorkerThread>( in SetUp()
43 worker_b_ = MakeRefCounted<WorkerThread>( in SetUp()
47 worker_c_ = MakeRefCounted<WorkerThread>( in SetUp()
57 scoped_refptr<WorkerThread> worker_a_;
58 scoped_refptr<WorkerThread> worker_b_;
[all …]
|
| D | worker_thread_unittest.cc | 61 class WorkerThreadDefaultDelegate : public WorkerThread::Delegate {
69 WorkerThread::ThreadLabel GetThreadLabel() const override { in GetThreadLabel()
70 return WorkerThread::ThreadLabel::DEDICATED; in GetThreadLabel()
72 void OnMainEntry(WorkerThread* worker) override {} in OnMainEntry()
73 RegisteredTaskSource GetWork(WorkerThread* worker) override { in GetWork()
96 worker_ = MakeRefCounted<WorkerThread>( in SetUp()
147 scoped_refptr<WorkerThread> worker_;
164 void OnMainEntry(WorkerThread* worker) override { in OnMainEntry()
176 RegisteredTaskSource GetWork(WorkerThread* worker) override { in GetWork()
463 RegisteredTaskSource GetWork(WorkerThread* worker) override { in GetWork()
[all …]
|
| D | pooled_single_thread_task_runner_manager.h | 31 class WorkerThread; variable
120 WorkerThread* CreateAndRegisterWorkerThread(
126 WorkerThread*& GetSharedWorkerThreadForTraits(const TaskTraits& traits);
128 void UnregisterWorkerThread(WorkerThread* worker);
142 std::vector<scoped_refptr<WorkerThread>> workers_ GUARDED_BY(lock_);
150 WorkerThread* shared_worker_threads_[ENVIRONMENT_COUNT]
154 WorkerThread* shared_com_worker_threads_
|
| /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
35 [](void* th) { static_cast<ThreadManager::WorkerThread*>(th)->Run(); }, in WorkerThread()
42 void ThreadManager::WorkerThread::Run() { in Run()
47 ThreadManager::WorkerThread::~WorkerThread() { in ~WorkerThread()
97 void ThreadManager::MarkAsCompleted(WorkerThread* thd) { in MarkAsCompleted()
116 std::list<WorkerThread*> completed_threads; in CleanupCompletedThreads()
143 WorkerThread* worker = new WorkerThread(this); in Initialize()
183 WorkerThread* worker = new WorkerThread(this); in MainWorkLoop()
|
| D | thread_manager.h | 120 class WorkerThread {
122 explicit WorkerThread(ThreadManager* thd_mgr);
123 ~WorkerThread();
141 void MarkAsCompleted(WorkerThread* thd);
176 std::list<WorkerThread*> completed_threads_;
|
| /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
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();
|
| /external/exoplayer/tree_8e57d3715f9092d5ec54ebe2e538f34bfcc34479/library/datasource/src/main/java/com/google/android/exoplayer2/upstream/cache/ |
| D | Cache.java | 19 import androidx.annotation.WorkerThread;
116 @WorkerThread
183 @WorkerThread
201 @WorkerThread
218 @WorkerThread
231 @WorkerThread
247 @WorkerThread
257 @WorkerThread
307 @WorkerThread
|
| D | CacheFileMetadataIndex.java | 24 import androidx.annotation.WorkerThread;
76 @WorkerThread
112 @WorkerThread
148 @WorkerThread
174 @WorkerThread
197 @WorkerThread
216 @WorkerThread
|
| /external/exoplayer/tree_15dc86382f17a24a3e881e52e31a810c1ea44b49/library/datasource/src/main/java/com/google/android/exoplayer2/upstream/cache/ |
| D | Cache.java | 19 import androidx.annotation.WorkerThread;
116 @WorkerThread
183 @WorkerThread
201 @WorkerThread
218 @WorkerThread
231 @WorkerThread
247 @WorkerThread
257 @WorkerThread
307 @WorkerThread
|
| D | CacheFileMetadataIndex.java | 24 import androidx.annotation.WorkerThread;
76 @WorkerThread
110 @WorkerThread
146 @WorkerThread
172 @WorkerThread
195 @WorkerThread
214 @WorkerThread
|
| /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/rust/crates/rayon-core/src/ |
| D | registry.rs | 212 if unsupported && WorkerThread::current().is_null() { in default_global_registry()
219 let worker_thread = Box::leak(Box::new(WorkerThread::from(thread))); in default_global_registry()
224 WorkerThread::set_current(worker_thread); in default_global_registry()
321 let worker_thread = WorkerThread::current(); in current()
336 let worker_thread = WorkerThread::current(); in current_num_threads()
346 pub(super) fn current_thread(&self) -> Option<&WorkerThread> { in current_thread() argument
348 let worker = WorkerThread::current().as_ref()?; in current_thread()
415 let worker_thread = WorkerThread::current(); in inject_or_push()
508 OP: FnOnce(&WorkerThread, bool) -> R + Send, in in_worker() argument
512 let worker_thread = WorkerThread::current(); in in_worker()
[all …]
|
| /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 …]
|
| /external/lottie/lottie/src/main/java/com/airbnb/lottie/ |
| D | LottieCompositionFactory.java | 15 import androidx.annotation.WorkerThread;
110 @WorkerThread
121 @WorkerThread
168 @WorkerThread
183 @WorkerThread
238 @WorkerThread
252 @WorkerThread
289 @WorkerThread
295 @WorkerThread
324 @WorkerThread
[all …]
|
| /external/crosvm/base/src/ |
| D | worker_thread.rs | 15 pub struct WorkerThread<T: Send + 'static> { struct
19 impl<T: Send + 'static> WorkerThread<T> { impl
38 WorkerThread { in start()
77 impl<T: Send + 'static> Drop for WorkerThread<T> { implementation
|
| /external/rust/crates/rayon-core/src/scope/ |
| D | mod.rs | 11 use crate::registry::{global_registry, in_worker, Registry, WorkerThread};
438 let thread = unsafe { WorkerThread::current().as_ref() }; in do_in_place_scope()
475 let thread = unsafe { WorkerThread::current().as_ref() }; in do_in_place_scope_fifo()
481 fn new(owner: Option<&WorkerThread>, registry: Option<&Arc<Registry>>) -> Self { in new() argument
577 fn new(owner: Option<&WorkerThread>, registry: Option<&Arc<Registry>>) -> Self { in new() argument
644 fn new(owner: Option<&WorkerThread>, registry: Option<&Arc<Registry>>) -> Self { in new() argument
687 fn complete<FUNC, R>(&self, owner: Option<&WorkerThread>, func: FUNC) -> R in complete() argument
758 fn new(owner: Option<&WorkerThread>) -> Self { in new()
762 pub(super) fn with_count(count: usize, owner: Option<&WorkerThread>) -> Self { in with_count()
782 pub(super) fn wait(&self, owner: Option<&WorkerThread>) { in wait() argument
|