Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(738)

Unified Diff: base/task_scheduler/scheduler_worker_thread.h

Issue 2077093002: Rename SchedulerWorkerThread* to SchedulerWorker* (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@rename2
Patch Set: CR Feedback Created 4 years, 6 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
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_
« no previous file with comments | « base/task_scheduler/scheduler_worker_stack_unittest.cc ('k') | base/task_scheduler/scheduler_worker_thread.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698