OLD | NEW |
1 // Copyright 2016 The Chromium Authors. All rights reserved. | 1 // Copyright 2016 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "base/task_scheduler/scheduler_worker_pool_impl.h" | 5 #include "base/task_scheduler/scheduler_worker_pool_impl.h" |
6 | 6 |
7 #include <stddef.h> | 7 #include <stddef.h> |
8 | 8 |
9 #include <algorithm> | 9 #include <algorithm> |
10 #include <utility> | 10 #include <utility> |
(...skipping 429 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
440 sequence_sort_key); | 440 sequence_sort_key); |
441 | 441 |
442 // Wake up a worker to process |sequence|. | 442 // Wake up a worker to process |sequence|. |
443 if (worker) | 443 if (worker) |
444 WakeUpWorker(worker); | 444 WakeUpWorker(worker); |
445 else | 445 else |
446 WakeUpOneWorker(); | 446 WakeUpOneWorker(); |
447 } | 447 } |
448 } | 448 } |
449 | 449 |
| 450 void SchedulerWorkerPoolImpl::GetHistograms( |
| 451 std::vector<const HistogramBase*>* histograms) const { |
| 452 histograms->push_back(detach_duration_histogram_); |
| 453 histograms->push_back(num_tasks_between_waits_histogram_); |
| 454 } |
| 455 |
450 SchedulerWorkerPoolImpl::SchedulerSingleThreadTaskRunner:: | 456 SchedulerWorkerPoolImpl::SchedulerSingleThreadTaskRunner:: |
451 SchedulerSingleThreadTaskRunner(const TaskTraits& traits, | 457 SchedulerSingleThreadTaskRunner(const TaskTraits& traits, |
452 SchedulerWorkerPool* worker_pool, | 458 SchedulerWorkerPool* worker_pool, |
453 SchedulerWorker* worker) | 459 SchedulerWorker* worker) |
454 : traits_(traits), | 460 : traits_(traits), |
455 worker_pool_(worker_pool), | 461 worker_pool_(worker_pool), |
456 worker_(worker) { | 462 worker_(worker) { |
457 DCHECK(worker_pool_); | 463 DCHECK(worker_pool_); |
458 DCHECK(worker_); | 464 DCHECK(worker_); |
459 static_cast<SchedulerWorkerDelegateImpl*>(worker_->delegate())-> | 465 static_cast<SchedulerWorkerDelegateImpl*>(worker_->delegate())-> |
(...skipping 326 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
786 AutoSchedulerLock auto_lock(idle_workers_stack_lock_); | 792 AutoSchedulerLock auto_lock(idle_workers_stack_lock_); |
787 idle_workers_stack_.Remove(worker); | 793 idle_workers_stack_.Remove(worker); |
788 } | 794 } |
789 | 795 |
790 bool SchedulerWorkerPoolImpl::CanWorkerDetachForTesting() { | 796 bool SchedulerWorkerPoolImpl::CanWorkerDetachForTesting() { |
791 return !worker_detachment_disallowed_.IsSet(); | 797 return !worker_detachment_disallowed_.IsSet(); |
792 } | 798 } |
793 | 799 |
794 } // namespace internal | 800 } // namespace internal |
795 } // namespace base | 801 } // namespace base |
OLD | NEW |