Index: base/task_scheduler/scheduler_worker_thread.h |
diff --git a/base/task_scheduler/scheduler_worker_thread.h b/base/task_scheduler/scheduler_worker_thread.h |
deleted file mode 100644 |
index b6f0860da0ee83cc5f3d3c30ac4f908384185585..0000000000000000000000000000000000000000 |
--- a/base/task_scheduler/scheduler_worker_thread.h |
+++ /dev/null |
@@ -1,114 +0,0 @@ |
-// Copyright 2016 The Chromium Authors. All rights reserved. |
-// Use of this source code is governed by a BSD-style license that can be |
-// found in the LICENSE file. |
- |
-#ifndef BASE_TASK_SCHEDULER_SCHEDULER_WORKER_THREAD_H_ |
-#define BASE_TASK_SCHEDULER_SCHEDULER_WORKER_THREAD_H_ |
- |
-#include <memory> |
- |
-#include "base/base_export.h" |
-#include "base/macros.h" |
-#include "base/memory/ref_counted.h" |
-#include "base/synchronization/waitable_event.h" |
-#include "base/task_scheduler/scheduler_lock.h" |
-#include "base/task_scheduler/sequence.h" |
-#include "base/threading/platform_thread.h" |
-#include "base/time/time.h" |
- |
-namespace base { |
-namespace internal { |
- |
-class TaskTracker; |
- |
-// A thread that runs Tasks from Sequences returned by a delegate. |
-// |
-// A SchedulerWorkerThread starts out sleeping. It is woken up by a call to |
-// WakeUp(). After a wake-up, a SchedulerWorkerThread runs Tasks from Sequences |
-// returned by the GetWork() method of its delegate as long as it doesn't return |
-// nullptr. It also periodically checks with its TaskTracker whether shutdown |
-// has completed and exits when it has. |
-// |
-// This class is thread-safe. |
-class BASE_EXPORT SchedulerWorkerThread : public PlatformThread::Delegate { |
- public: |
- // Delegate interface for SchedulerWorkerThread. The methods are always called |
- // from the thread managed by the SchedulerWorkerThread instance. |
- class Delegate { |
- public: |
- virtual ~Delegate() = default; |
- |
- // Called by |worker_thread| when it enters its main function. |
- virtual void OnMainEntry(SchedulerWorkerThread* worker_thread) = 0; |
- |
- // Called by |worker_thread| to get a Sequence from which to run a Task. |
- virtual scoped_refptr<Sequence> GetWork( |
- SchedulerWorkerThread* worker_thread) = 0; |
- |
- // Called when |sequence| isn't empty after the SchedulerWorkerThread pops a |
- // Task from it. |sequence| is the last Sequence returned by GetWork(). |
- virtual void ReEnqueueSequence(scoped_refptr<Sequence> sequence) = 0; |
- |
- // Called by |worker_thread| to determine how long to sleep before the next |
- // call to GetWork(). GetWork() may be called before this timeout expires |
- // if the thread's WakeUp() method is called. |
- virtual TimeDelta GetSleepTimeout() = 0; |
- }; |
- |
- // Creates a SchedulerWorkerThread with priority |thread_priority| that runs |
- // Tasks from Sequences returned by |delegate|. |task_tracker| is used to |
- // handle shutdown behavior of Tasks. Returns nullptr if creating the |
- // underlying platform thread fails. |
- static std::unique_ptr<SchedulerWorkerThread> Create( |
- ThreadPriority thread_priority, |
- std::unique_ptr<Delegate> delegate, |
- TaskTracker* task_tracker); |
- |
- // Destroying a SchedulerWorkerThread in production is not allowed; it is |
- // always leaked. In tests, it can only be destroyed after JoinForTesting() |
- // has returned. |
- ~SchedulerWorkerThread() override; |
- |
- // Wakes up this SchedulerWorkerThread if it wasn't already awake. After this |
- // is called, this SchedulerWorkerThread will run Tasks from Sequences |
- // returned by the GetWork() method of its delegate until it returns nullptr. |
- void WakeUp(); |
- |
- SchedulerWorkerThread::Delegate* delegate() { return delegate_.get(); } |
- |
- // Joins this SchedulerWorkerThread. If a Task is already running, it will be |
- // allowed to complete its execution. This can only be called once. |
- void JoinForTesting(); |
- |
- private: |
- SchedulerWorkerThread(ThreadPriority thread_priority, |
- std::unique_ptr<Delegate> delegate, |
- TaskTracker* task_tracker); |
- |
- // PlatformThread::Delegate: |
- void ThreadMain() override; |
- |
- bool ShouldExitForTesting() const; |
- |
- // Platform thread managed by this SchedulerWorkerThread. |
- PlatformThreadHandle thread_handle_; |
- |
- // Event signaled to wake up this SchedulerWorkerThread. |
- WaitableEvent wake_up_event_; |
- |
- const std::unique_ptr<Delegate> delegate_; |
- TaskTracker* const task_tracker_; |
- |
- // Synchronizes access to |should_exit_for_testing_|. |
- mutable SchedulerLock should_exit_for_testing_lock_; |
- |
- // True once JoinForTesting() has been called. |
- bool should_exit_for_testing_ = false; |
- |
- DISALLOW_COPY_AND_ASSIGN(SchedulerWorkerThread); |
-}; |
- |
-} // namespace internal |
-} // namespace base |
- |
-#endif // BASE_TASK_SCHEDULER_SCHEDULER_WORKER_THREAD_H_ |