Lines Matching refs:SequencedWorkerPool
56 shutdown_behavior(SequencedWorkerPool::BLOCK_SHUTDOWN) {} in SequencedTask()
63 shutdown_behavior(SequencedWorkerPool::BLOCK_SHUTDOWN) {} in SequencedTask()
70 SequencedWorkerPool::WorkerShutdown shutdown_behavior;
101 const scoped_refptr<SequencedWorkerPool>& pool,
102 SequencedWorkerPool::WorkerShutdown shutdown_behavior);
113 const scoped_refptr<SequencedWorkerPool> pool_;
115 const SequencedWorkerPool::WorkerShutdown shutdown_behavior_;
121 const scoped_refptr<SequencedWorkerPool>& pool, in SequencedWorkerPoolTaskRunner()
122 SequencedWorkerPool::WorkerShutdown shutdown_behavior) in SequencedWorkerPoolTaskRunner()
153 const scoped_refptr<SequencedWorkerPool>& pool,
154 SequencedWorkerPool::SequenceToken token,
155 SequencedWorkerPool::WorkerShutdown shutdown_behavior);
171 const scoped_refptr<SequencedWorkerPool> pool_;
173 const SequencedWorkerPool::SequenceToken token_;
175 const SequencedWorkerPool::WorkerShutdown shutdown_behavior_;
181 const scoped_refptr<SequencedWorkerPool>& pool, in SequencedWorkerPoolSequencedTaskRunner()
182 SequencedWorkerPool::SequenceToken token, in SequencedWorkerPoolSequencedTaskRunner()
183 SequencedWorkerPool::WorkerShutdown shutdown_behavior) in SequencedWorkerPoolSequencedTaskRunner()
229 class SequencedWorkerPool::Worker : public SimpleThread {
233 Worker(const scoped_refptr<SequencedWorkerPool>& worker_pool,
269 scoped_refptr<SequencedWorkerPool> worker_pool() const { in worker_pool()
274 static LazyInstance<ThreadLocalPointer<SequencedWorkerPool::Worker>>::Leaky
277 scoped_refptr<SequencedWorkerPool> worker_pool_;
292 class SequencedWorkerPool::Inner {
296 Inner(SequencedWorkerPool* worker_pool, size_t max_threads,
419 SequencedWorkerPool* const worker_pool_;
506 SequencedWorkerPool::Worker::Worker( in Worker()
507 const scoped_refptr<SequencedWorkerPool>& worker_pool, in Worker()
517 SequencedWorkerPool::Worker::~Worker() { in ~Worker()
520 void SequencedWorkerPool::Worker::Run() { in Run()
541 SequencedWorkerPool::Worker*
542 SequencedWorkerPool::Worker::GetForCurrentThread() { in GetForCurrentThread()
551 LazyInstance<ThreadLocalPointer<SequencedWorkerPool::Worker>>::Leaky
552 SequencedWorkerPool::Worker::lazy_tls_ptr_ = LAZY_INSTANCE_INITIALIZER;
556 SequencedWorkerPool::Inner::Inner( in Inner()
557 SequencedWorkerPool* worker_pool, in Inner()
580 SequencedWorkerPool::Inner::~Inner() { in ~Inner()
595 SequencedWorkerPool::SequenceToken
596 SequencedWorkerPool::Inner::GetSequenceToken() { in GetSequenceToken()
602 SequencedWorkerPool::SequenceToken
603 SequencedWorkerPool::Inner::GetNamedSequenceToken(const std::string& name) { in GetNamedSequenceToken()
608 bool SequencedWorkerPool::Inner::PostTask( in PostTask()
680 bool SequencedWorkerPool::Inner::RunsTasksOnCurrentThread() const { in RunsTasksOnCurrentThread()
685 bool SequencedWorkerPool::Inner::IsRunningSequenceOnCurrentThread( in IsRunningSequenceOnCurrentThread()
695 bool SequencedWorkerPool::Inner::IsRunningSequence( in IsRunningSequence()
702 void SequencedWorkerPool::Inner::SetRunningTaskInfoForCurrentThread( in SetRunningTaskInfoForCurrentThread()
718 void SequencedWorkerPool::Inner::CleanupForTesting() { in CleanupForTesting()
734 void SequencedWorkerPool::Inner::SignalHasWorkForTesting() { in SignalHasWorkForTesting()
738 void SequencedWorkerPool::Inner::Shutdown( in Shutdown()
781 bool SequencedWorkerPool::Inner::IsShutdownInProgress() { in IsShutdownInProgress()
786 void SequencedWorkerPool::Inner::ThreadLoop(Worker* this_worker) { in ThreadLoop()
924 void SequencedWorkerPool::Inner::HandleCleanup() { in HandleCleanup()
964 int SequencedWorkerPool::Inner::LockedGetNamedTokenID( in LockedGetNamedTokenID()
980 int64_t SequencedWorkerPool::Inner::LockedGetNextSequenceTaskNumber() { in LockedGetNextSequenceTaskNumber()
986 SequencedWorkerPool::Inner::GetWorkStatus SequencedWorkerPool::Inner::GetWork( in GetWork()
1075 int SequencedWorkerPool::Inner::WillRunWorkerTask(const SequencedTask& task) { in WillRunWorkerTask()
1106 void SequencedWorkerPool::Inner::DidRunWorkerTask(const SequencedTask& task) { in DidRunWorkerTask()
1118 bool SequencedWorkerPool::Inner::IsSequenceTokenRunnable( in IsSequenceTokenRunnable()
1126 int SequencedWorkerPool::Inner::PrepareToStartAdditionalThreadIfHelpful() { in PrepareToStartAdditionalThreadIfHelpful()
1175 void SequencedWorkerPool::Inner::FinishStartingAdditionalThread( in FinishStartingAdditionalThread()
1185 void SequencedWorkerPool::Inner::SignalHasWork() { in SignalHasWork()
1192 bool SequencedWorkerPool::Inner::CanShutdown() const { in CanShutdown()
1201 SequencedWorkerPool::Inner::g_last_sequence_number_;
1205 std::string SequencedWorkerPool::SequenceToken::ToString() const { in ToString()
1210 SequencedWorkerPool::SequenceToken
1211 SequencedWorkerPool::GetSequenceTokenForCurrentThread() { in GetSequenceTokenForCurrentThread()
1220 scoped_refptr<SequencedWorkerPool>
1221 SequencedWorkerPool::GetWorkerPoolForCurrentThread() { in GetWorkerPoolForCurrentThread()
1231 SequencedWorkerPool::GetSequencedTaskRunnerForCurrentThread() { in GetSequencedTaskRunnerForCurrentThread()
1239 scoped_refptr<SequencedWorkerPool> pool = worker->worker_pool(); in GetSequencedTaskRunnerForCurrentThread()
1256 SequencedWorkerPool::SequencedWorkerPool(size_t max_threads, in SequencedWorkerPool() function in base::SequencedWorkerPool
1262 SequencedWorkerPool::SequencedWorkerPool(size_t max_threads, in SequencedWorkerPool() function in base::SequencedWorkerPool
1269 SequencedWorkerPool::~SequencedWorkerPool() {} in ~SequencedWorkerPool()
1271 void SequencedWorkerPool::OnDestruct() const { in OnDestruct()
1281 SequencedWorkerPool::SequenceToken SequencedWorkerPool::GetSequenceToken() { in GetSequenceToken()
1285 SequencedWorkerPool::SequenceToken SequencedWorkerPool::GetNamedSequenceToken( in GetNamedSequenceToken()
1290 scoped_refptr<SequencedTaskRunner> SequencedWorkerPool::GetSequencedTaskRunner( in GetSequencedTaskRunner()
1296 SequencedWorkerPool::GetSequencedTaskRunnerWithShutdownBehavior( in GetSequencedTaskRunnerWithShutdownBehavior()
1303 SequencedWorkerPool::GetTaskRunnerWithShutdownBehavior( in GetTaskRunnerWithShutdownBehavior()
1308 bool SequencedWorkerPool::PostWorkerTask( in PostWorkerTask()
1315 bool SequencedWorkerPool::PostDelayedWorkerTask( in PostDelayedWorkerTask()
1325 bool SequencedWorkerPool::PostWorkerTaskWithShutdownBehavior( in PostWorkerTaskWithShutdownBehavior()
1333 bool SequencedWorkerPool::PostSequencedWorkerTask( in PostSequencedWorkerTask()
1341 bool SequencedWorkerPool::PostDelayedSequencedWorkerTask( in PostDelayedSequencedWorkerTask()
1352 bool SequencedWorkerPool::PostNamedSequencedWorkerTask( in PostNamedSequencedWorkerTask()
1361 bool SequencedWorkerPool::PostSequencedWorkerTaskWithShutdownBehavior( in PostSequencedWorkerTaskWithShutdownBehavior()
1370 bool SequencedWorkerPool::PostDelayedTask( in PostDelayedTask()
1377 bool SequencedWorkerPool::RunsTasksOnCurrentThread() const { in RunsTasksOnCurrentThread()
1381 bool SequencedWorkerPool::IsRunningSequenceOnCurrentThread( in IsRunningSequenceOnCurrentThread()
1386 bool SequencedWorkerPool::IsRunningSequence( in IsRunningSequence()
1391 void SequencedWorkerPool::FlushForTesting() { in FlushForTesting()
1395 void SequencedWorkerPool::SignalHasWorkForTesting() { in SignalHasWorkForTesting()
1399 void SequencedWorkerPool::Shutdown(int max_new_blocking_tasks_after_shutdown) { in Shutdown()
1404 bool SequencedWorkerPool::IsShutdownInProgress() { in IsShutdownInProgress()