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 #ifndef BASE_TASK_SCHEDULER_SCHEDULER_WORKER_POOL_IMPL_H_ | 5 #ifndef BASE_TASK_SCHEDULER_SCHEDULER_WORKER_POOL_IMPL_H_ |
6 #define BASE_TASK_SCHEDULER_SCHEDULER_WORKER_POOL_IMPL_H_ | 6 #define BASE_TASK_SCHEDULER_SCHEDULER_WORKER_POOL_IMPL_H_ |
7 | 7 |
8 #include <stddef.h> | 8 #include <stddef.h> |
9 | 9 |
10 #include <memory> | 10 #include <memory> |
(...skipping 20 matching lines...) Expand all Loading... |
31 | 31 |
32 class HistogramBase; | 32 class HistogramBase; |
33 class SchedulerWorkerPoolParams; | 33 class SchedulerWorkerPoolParams; |
34 class TaskTraits; | 34 class TaskTraits; |
35 | 35 |
36 namespace internal { | 36 namespace internal { |
37 | 37 |
38 class DelayedTaskManager; | 38 class DelayedTaskManager; |
39 class TaskTracker; | 39 class TaskTracker; |
40 | 40 |
41 // A pool of workers that run Tasks. This class is thread-safe. | 41 // A pool of workers that run Tasks. |
| 42 // |
| 43 // The pool doesn't create threads until Start() is called. Tasks can be posted |
| 44 // at any time but will not run until after Start() is called. |
| 45 // |
| 46 // This class is thread-safe. |
42 class BASE_EXPORT SchedulerWorkerPoolImpl : public SchedulerWorkerPool { | 47 class BASE_EXPORT SchedulerWorkerPoolImpl : public SchedulerWorkerPool { |
43 public: | 48 public: |
44 // Callback invoked when a Sequence isn't empty after a worker pops a Task | 49 // Callback invoked when a Sequence isn't empty after a worker pops a Task |
45 // from it. | 50 // from it. |
46 using ReEnqueueSequenceCallback = Callback<void(scoped_refptr<Sequence>)>; | 51 using ReEnqueueSequenceCallback = Callback<void(scoped_refptr<Sequence>)>; |
47 | 52 |
48 // Constructs a pool without workers. Tasks can be posted to the pool, but | 53 // Constructs a pool without workers. |
49 // they won't run until workers are created. To create workers and start | |
50 // running tasks, call Start(). | |
51 // | 54 // |
52 // |name| is used to label the pool's threads ("TaskScheduler" + |name| + | 55 // |name| is used to label the pool's threads ("TaskScheduler" + |name| + |
53 // index) and histograms ("TaskScheduler." + histogram name + "." + |name| + | 56 // index) and histograms ("TaskScheduler." + histogram name + "." + |name| + |
54 // extra suffixes). |priority_hint| is the preferred thread priority; the | 57 // extra suffixes). |priority_hint| is the preferred thread priority; the |
55 // actual thread priority depends on shutdown state and platform capabilities. | 58 // actual thread priority depends on shutdown state and platform capabilities. |
56 // |re_enqueue_sequence_callback| is invoked when a Sequence isn't empty after | 59 // |re_enqueue_sequence_callback| is invoked when a Sequence isn't empty after |
57 // a worker pops a Task from it. |task_tracker| keeps track of tasks. | 60 // a worker pops a Task from it. |task_tracker| keeps track of tasks. |
58 // |delayed_task_manager| handles tasks posted with a delay. | 61 // |delayed_task_manager| handles tasks posted with a delay. |
59 SchedulerWorkerPoolImpl( | 62 SchedulerWorkerPoolImpl( |
60 const std::string& name, | 63 const std::string& name, |
(...skipping 143 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
204 TaskTracker* const task_tracker_; | 207 TaskTracker* const task_tracker_; |
205 DelayedTaskManager* const delayed_task_manager_; | 208 DelayedTaskManager* const delayed_task_manager_; |
206 | 209 |
207 DISALLOW_COPY_AND_ASSIGN(SchedulerWorkerPoolImpl); | 210 DISALLOW_COPY_AND_ASSIGN(SchedulerWorkerPoolImpl); |
208 }; | 211 }; |
209 | 212 |
210 } // namespace internal | 213 } // namespace internal |
211 } // namespace base | 214 } // namespace base |
212 | 215 |
213 #endif // BASE_TASK_SCHEDULER_SCHEDULER_WORKER_POOL_IMPL_H_ | 216 #endif // BASE_TASK_SCHEDULER_SCHEDULER_WORKER_POOL_IMPL_H_ |
OLD | NEW |