Lines Matching defs:SequencedWorkerPool
56 shutdown_behavior(SequencedWorkerPool::BLOCK_SHUTDOWN) {}
63 shutdown_behavior(SequencedWorkerPool::BLOCK_SHUTDOWN) {}
70 SequencedWorkerPool::WorkerShutdown shutdown_behavior;
94 // A TaskRunner which posts tasks to a SequencedWorkerPool with a
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,
122 SequencedWorkerPool::WorkerShutdown shutdown_behavior)
146 // A SequencedTaskRunner which posts tasks to a SequencedWorkerPool with a
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,
182 SequencedWorkerPool::SequenceToken token,
183 SequencedWorkerPool::WorkerShutdown shutdown_behavior)
229 class SequencedWorkerPool::Worker : public SimpleThread {
233 Worker(const scoped_refptr<SequencedWorkerPool>& worker_pool,
269 scoped_refptr<SequencedWorkerPool> worker_pool() const {
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_;
424 // GetSequenceToken unique across SequencedWorkerPool instances.
506 SequencedWorkerPool::Worker::Worker(
507 const scoped_refptr<SequencedWorkerPool>& worker_pool,
517 SequencedWorkerPool::Worker::~Worker() {
520 void SequencedWorkerPool::Worker::Run() {
541 SequencedWorkerPool::Worker*
542 SequencedWorkerPool::Worker::GetForCurrentThread() {
551 LazyInstance<ThreadLocalPointer<SequencedWorkerPool::Worker>>::Leaky
552 SequencedWorkerPool::Worker::lazy_tls_ptr_ = LAZY_INSTANCE_INITIALIZER;
556 SequencedWorkerPool::Inner::Inner(
557 SequencedWorkerPool* worker_pool,
580 SequencedWorkerPool::Inner::~Inner() {
595 SequencedWorkerPool::SequenceToken
596 SequencedWorkerPool::Inner::GetSequenceToken() {
602 SequencedWorkerPool::SequenceToken
603 SequencedWorkerPool::Inner::GetNamedSequenceToken(const std::string& name) {
608 bool SequencedWorkerPool::Inner::PostTask(
653 "SequencedWorkerPool::Inner::PostTask",
680 bool SequencedWorkerPool::Inner::RunsTasksOnCurrentThread() const {
685 bool SequencedWorkerPool::Inner::IsRunningSequenceOnCurrentThread(
695 bool SequencedWorkerPool::Inner::IsRunningSequence(
702 void SequencedWorkerPool::Inner::SetRunningTaskInfoForCurrentThread(
718 void SequencedWorkerPool::Inner::CleanupForTesting() {
734 void SequencedWorkerPool::Inner::SignalHasWorkForTesting() {
738 void SequencedWorkerPool::Inner::Shutdown(
776 UMA_HISTOGRAM_TIMES("SequencedWorkerPool.ShutdownDelayTime",
781 bool SequencedWorkerPool::Inner::IsShutdownInProgress() {
786 void SequencedWorkerPool::Inner::ThreadLoop(Worker* this_worker) {
811 "SequencedWorkerPool::Inner::ThreadLoop",
924 void SequencedWorkerPool::Inner::HandleCleanup() {
964 int SequencedWorkerPool::Inner::LockedGetNamedTokenID(
980 int64_t SequencedWorkerPool::Inner::LockedGetNextSequenceTaskNumber() {
986 SequencedWorkerPool::Inner::GetWorkStatus SequencedWorkerPool::Inner::GetWork(
1075 int SequencedWorkerPool::Inner::WillRunWorkerTask(const SequencedTask& task) {
1106 void SequencedWorkerPool::Inner::DidRunWorkerTask(const SequencedTask& task) {
1118 bool SequencedWorkerPool::Inner::IsSequenceTokenRunnable(
1126 int SequencedWorkerPool::Inner::PrepareToStartAdditionalThreadIfHelpful() {
1175 void SequencedWorkerPool::Inner::FinishStartingAdditionalThread(
1185 void SequencedWorkerPool::Inner::SignalHasWork() {
1192 bool SequencedWorkerPool::Inner::CanShutdown() const {
1201 SequencedWorkerPool::Inner::g_last_sequence_number_;
1203 // SequencedWorkerPool --------------------------------------------------------
1205 std::string SequencedWorkerPool::SequenceToken::ToString() const {
1210 SequencedWorkerPool::SequenceToken
1211 SequencedWorkerPool::GetSequenceTokenForCurrentThread() {
1220 scoped_refptr<SequencedWorkerPool>
1221 SequencedWorkerPool::GetWorkerPoolForCurrentThread() {
1231 SequencedWorkerPool::GetSequencedTaskRunnerForCurrentThread() {
1239 scoped_refptr<SequencedWorkerPool> pool = worker->worker_pool();
1256 SequencedWorkerPool::SequencedWorkerPool(size_t max_threads,
1262 SequencedWorkerPool::SequencedWorkerPool(size_t max_threads,
1269 SequencedWorkerPool::~SequencedWorkerPool() {}
1271 void SequencedWorkerPool::OnDestruct() const {
1281 SequencedWorkerPool::SequenceToken SequencedWorkerPool::GetSequenceToken() {
1285 SequencedWorkerPool::SequenceToken SequencedWorkerPool::GetNamedSequenceToken(
1290 scoped_refptr<SequencedTaskRunner> SequencedWorkerPool::GetSequencedTaskRunner(
1296 SequencedWorkerPool::GetSequencedTaskRunnerWithShutdownBehavior(
1303 SequencedWorkerPool::GetTaskRunnerWithShutdownBehavior(
1308 bool SequencedWorkerPool::PostWorkerTask(
1315 bool SequencedWorkerPool::PostDelayedWorkerTask(
1325 bool SequencedWorkerPool::PostWorkerTaskWithShutdownBehavior(
1333 bool SequencedWorkerPool::PostSequencedWorkerTask(
1341 bool SequencedWorkerPool::PostDelayedSequencedWorkerTask(
1352 bool SequencedWorkerPool::PostNamedSequencedWorkerTask(
1361 bool SequencedWorkerPool::PostSequencedWorkerTaskWithShutdownBehavior(
1370 bool SequencedWorkerPool::PostDelayedTask(
1377 bool SequencedWorkerPool::RunsTasksOnCurrentThread() const {
1381 bool SequencedWorkerPool::IsRunningSequenceOnCurrentThread(
1386 bool SequencedWorkerPool::IsRunningSequence(
1391 void SequencedWorkerPool::FlushForTesting() {
1395 void SequencedWorkerPool::SignalHasWorkForTesting() {
1399 void SequencedWorkerPool::Shutdown(int max_new_blocking_tasks_after_shutdown) {
1404 bool SequencedWorkerPool::IsShutdownInProgress() {
