OLD | NEW |
| (Empty) |
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 | |
3 // found in the LICENSE file. | |
4 | |
5 #ifndef BASE_TASK_SCHEDULER_SCHEDULER_THREAD_POOL_H_ | |
6 #define BASE_TASK_SCHEDULER_SCHEDULER_THREAD_POOL_H_ | |
7 | |
8 #include <memory> | |
9 | |
10 #include "base/base_export.h" | |
11 #include "base/memory/ref_counted.h" | |
12 #include "base/task_runner.h" | |
13 #include "base/task_scheduler/sequence.h" | |
14 #include "base/task_scheduler/task.h" | |
15 #include "base/task_scheduler/task_traits.h" | |
16 | |
17 namespace base { | |
18 namespace internal { | |
19 | |
20 class SchedulerWorkerThread; | |
21 class SequenceSortKey; | |
22 | |
23 // Interface for a thread pool. | |
24 class BASE_EXPORT SchedulerThreadPool { | |
25 public: | |
26 virtual ~SchedulerThreadPool() = default; | |
27 | |
28 // Returns a TaskRunner whose PostTask invocations will result in scheduling | |
29 // Tasks with |traits| and |execution_mode| in this SchedulerThreadPool. | |
30 virtual scoped_refptr<TaskRunner> CreateTaskRunnerWithTraits( | |
31 const TaskTraits& traits, | |
32 ExecutionMode execution_mode) = 0; | |
33 | |
34 // Inserts |sequence| with |sequence_sort_key| into a queue of Sequences that | |
35 // can be processed by any worker thread owned by this SchedulerThreadPool. | |
36 // Must only be used to put |sequence| back into a queue after running a Task | |
37 // from it. The thread that calls this doesn't have to belong to this | |
38 // SchedulerThreadPool. | |
39 virtual void ReEnqueueSequence(scoped_refptr<Sequence> sequence, | |
40 const SequenceSortKey& sequence_sort_key) = 0; | |
41 | |
42 // Posts |task| to be executed by this SchedulerThreadPool as part of | |
43 // |sequence|. If |worker_thread| is non-null, |task| will be scheduled to run | |
44 // on it specifically (note: |worker_thread| must be owned by this | |
45 // SchedulerThreadPool); otherwise, |task| will be added to the pending shared | |
46 // work. |task| won't be executed before its delayed run time, if any. Returns | |
47 // true if |task| is posted. | |
48 virtual bool PostTaskWithSequence(std::unique_ptr<Task> task, | |
49 scoped_refptr<Sequence> sequence, | |
50 SchedulerWorkerThread* worker_thread) = 0; | |
51 | |
52 // Posts |task| to be executed by this SchedulerThreadPool as part of | |
53 // |sequence|. If |worker_thread| is non-null, |task| will be scheduled to run | |
54 // on it specifically (note: |worker_thread| must be owned by this | |
55 // SchedulerThreadPool); otherwise, |task| will be added to the pending shared | |
56 // work. This must only be called after |task| has gone through | |
57 // PostTaskWithSequence() and after |task|'s delayed run time. | |
58 virtual void PostTaskWithSequenceNow( | |
59 std::unique_ptr<Task> task, | |
60 scoped_refptr<Sequence> sequence, | |
61 SchedulerWorkerThread* worker_thread) = 0; | |
62 }; | |
63 | |
64 } // namespace internal | |
65 } // namespace base | |
66 | |
67 #endif // BASE_TASK_SCHEDULER_SCHEDULER_THREAD_POOL_H_ | |
OLD | NEW |