Lines Matching defs:SequencedWorkerPool
52 shutdown_behavior(SequencedWorkerPool::BLOCK_SHUTDOWN) {}
59 shutdown_behavior(SequencedWorkerPool::BLOCK_SHUTDOWN) {}
66 SequencedWorkerPool::WorkerShutdown shutdown_behavior;
90 // A TaskRunner which posts tasks to a SequencedWorkerPool with a
97 const scoped_refptr<SequencedWorkerPool>& pool,
98 SequencedWorkerPool::WorkerShutdown shutdown_behavior);
109 const scoped_refptr<SequencedWorkerPool> pool_;
111 const SequencedWorkerPool::WorkerShutdown shutdown_behavior_;
117 const scoped_refptr<SequencedWorkerPool>& pool,
118 SequencedWorkerPool::WorkerShutdown shutdown_behavior)
142 // A SequencedTaskRunner which posts tasks to a SequencedWorkerPool with a
149 const scoped_refptr<SequencedWorkerPool>& pool,
150 SequencedWorkerPool::SequenceToken token,
151 SequencedWorkerPool::WorkerShutdown shutdown_behavior);
168 const scoped_refptr<SequencedWorkerPool> pool_;
170 const SequencedWorkerPool::SequenceToken token_;
172 const SequencedWorkerPool::WorkerShutdown shutdown_behavior_;
178 const scoped_refptr<SequencedWorkerPool>& pool,
179 SequencedWorkerPool::SequenceToken token,
180 SequencedWorkerPool::WorkerShutdown shutdown_behavior)
224 SequencedWorkerPool::SequenceToken> >::Leaky g_lazy_tls_ptr =
231 class SequencedWorkerPool::Worker : public SimpleThread {
235 Worker(const scoped_refptr<SequencedWorkerPool>& worker_pool,
258 scoped_refptr<SequencedWorkerPool> worker_pool_;
267 class SequencedWorkerPool::Inner {
271 Inner(SequencedWorkerPool* worker_pool, size_t max_threads,
394 SequencedWorkerPool* const worker_pool_;
399 // GetSequenceToken unique across SequencedWorkerPool instances.
481 SequencedWorkerPool::Worker::Worker(
482 const scoped_refptr<SequencedWorkerPool>& worker_pool,
491 SequencedWorkerPool::Worker::~Worker() {
494 void SequencedWorkerPool::Worker::Run() {
515 SequencedWorkerPool::Inner::Inner(
516 SequencedWorkerPool* worker_pool,
539 SequencedWorkerPool::Inner::~Inner() {
553 SequencedWorkerPool::SequenceToken
554 SequencedWorkerPool::Inner::GetSequenceToken() {
560 SequencedWorkerPool::SequenceToken
561 SequencedWorkerPool::Inner::GetNamedSequenceToken(const std::string& name) {
566 bool SequencedWorkerPool::Inner::PostTask(
602 "SequencedWorkerPool::PostTask",
628 bool SequencedWorkerPool::Inner::RunsTasksOnCurrentThread() const {
633 bool SequencedWorkerPool::Inner::IsRunningSequenceOnCurrentThread(
643 void SequencedWorkerPool::Inner::CleanupForTesting() {
659 void SequencedWorkerPool::Inner::SignalHasWorkForTesting() {
663 void SequencedWorkerPool::Inner::Shutdown(
701 UMA_HISTOGRAM_TIMES("SequencedWorkerPool.ShutdownDelayTime",
706 bool SequencedWorkerPool::Inner::IsShutdownInProgress() {
711 void SequencedWorkerPool::Inner::ThreadLoop(Worker* this_worker) {
736 "SequencedWorkerPool::PostTask",
738 TRACE_EVENT2("toplevel", "SequencedWorkerPool::ThreadLoop",
829 void SequencedWorkerPool::Inner::HandleCleanup() {
869 int SequencedWorkerPool::Inner::LockedGetNamedTokenID(
885 int64 SequencedWorkerPool::Inner::LockedGetNextSequenceTaskNumber() {
891 SequencedWorkerPool::WorkerShutdown
892 SequencedWorkerPool::Inner::LockedCurrentThreadShutdownBehavior() const {
900 SequencedWorkerPool::Inner::GetWorkStatus SequencedWorkerPool::Inner::GetWork(
907 UMA_HISTOGRAM_COUNTS_100("SequencedWorkerPool.TaskCount",
995 UMA_HISTOGRAM_COUNTS_100("SequencedWorkerPool.UnrunnableTaskCount",
1001 int SequencedWorkerPool::Inner::WillRunWorkerTask(const SequencedTask& task) {
1032 void SequencedWorkerPool::Inner::DidRunWorkerTask(const SequencedTask& task) {
1044 bool SequencedWorkerPool::Inner::IsSequenceTokenRunnable(
1052 int SequencedWorkerPool::Inner::PrepareToStartAdditionalThreadIfHelpful() {
1101 void SequencedWorkerPool::Inner::FinishStartingAdditionalThread(
1111 void SequencedWorkerPool::Inner::SignalHasWork() {
1118 bool SequencedWorkerPool::Inner::CanShutdown() const {
1127 SequencedWorkerPool::Inner::g_last_sequence_number_;
1129 // SequencedWorkerPool --------------------------------------------------------
1132 SequencedWorkerPool::SequenceToken
1133 SequencedWorkerPool::GetSequenceTokenForCurrentThread() {
1138 SequencedWorkerPool::SequenceToken* token = g_lazy_tls_ptr.Get().Get();
1144 SequencedWorkerPool::SequencedWorkerPool(
1151 SequencedWorkerPool::SequencedWorkerPool(
1159 SequencedWorkerPool::~SequencedWorkerPool() {}
1161 void SequencedWorkerPool::OnDestruct() const {
1172 SequencedWorkerPool::SequenceToken SequencedWorkerPool::GetSequenceToken() {
1176 SequencedWorkerPool::SequenceToken SequencedWorkerPool::GetNamedSequenceToken(
1181 scoped_refptr<SequencedTaskRunner> SequencedWorkerPool::GetSequencedTaskRunner(
1187 SequencedWorkerPool::GetSequencedTaskRunnerWithShutdownBehavior(
1194 SequencedWorkerPool::GetTaskRunnerWithShutdownBehavior(
1199 bool SequencedWorkerPool::PostWorkerTask(
1206 bool SequencedWorkerPool::PostDelayedWorkerTask(
1216 bool SequencedWorkerPool::PostWorkerTaskWithShutdownBehavior(
1224 bool SequencedWorkerPool::PostSequencedWorkerTask(
1232 bool SequencedWorkerPool::PostDelayedSequencedWorkerTask(
1243 bool SequencedWorkerPool::PostNamedSequencedWorkerTask(
1252 bool SequencedWorkerPool::PostSequencedWorkerTaskWithShutdownBehavior(
1261 bool SequencedWorkerPool::PostDelayedTask(
1268 bool SequencedWorkerPool::RunsTasksOnCurrentThread() const {
1272 bool SequencedWorkerPool::IsRunningSequenceOnCurrentThread(
1277 void SequencedWorkerPool::FlushForTesting() {
1281 void SequencedWorkerPool::SignalHasWorkForTesting() {
1285 void SequencedWorkerPool::Shutdown(int max_new_blocking_tasks_after_shutdown) {
1290 bool SequencedWorkerPool::IsShutdownInProgress() {