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

Unified Diff: content/renderer/raster_worker_pool.h

Issue 2021323002: content: Rename RasterWorkerPool -> CategorizedWorkerPool. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@task_graph_runner_test_2
Patch Set: rebase Created 4 years, 7 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
« no previous file with comments | « content/renderer/categorized_worker_pool_unittest.cc ('k') | content/renderer/raster_worker_pool.cc » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: content/renderer/raster_worker_pool.h
diff --git a/content/renderer/raster_worker_pool.h b/content/renderer/raster_worker_pool.h
deleted file mode 100644
index 10c312be68b1b2de4ab2e1102faa69b5103d987b..0000000000000000000000000000000000000000
--- a/content/renderer/raster_worker_pool.h
+++ /dev/null
@@ -1,148 +0,0 @@
-// Copyright 2015 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 CONTENT_RENDERER_RASTER_WORKER_POOL_H_
-#define CONTENT_RENDERER_RASTER_WORKER_POOL_H_
-
-#include <memory>
-
-#include "base/callback.h"
-#include "base/containers/hash_tables.h"
-#include "base/macros.h"
-#include "base/sequenced_task_runner.h"
-#include "base/synchronization/condition_variable.h"
-#include "base/task_runner.h"
-#include "base/threading/simple_thread.h"
-#include "cc/raster/task_category.h"
-#include "cc/raster/task_graph_runner.h"
-#include "cc/raster/task_graph_work_queue.h"
-#include "content/common/content_export.h"
-
-namespace content {
-
-// A pool of threads used to run raster work.
-// Work can be scheduled on the threads using different interfaces.
-// The pool itself implements TaskRunner interface and tasks posted via that
-// interface might run in parallel.
-// CreateSequencedTaskRunner creates a sequenced task runner that might run in
-// parallel with other instances of sequenced task runners.
-// It's also possible to get the underlying TaskGraphRunner to schedule a graph
-// of tasks with their dependencies.
-class CONTENT_EXPORT RasterWorkerPool : public base::TaskRunner,
- public cc::TaskGraphRunner {
- public:
- RasterWorkerPool();
-
- // Overridden from base::TaskRunner:
- bool PostDelayedTask(const tracked_objects::Location& from_here,
- const base::Closure& task,
- base::TimeDelta delay) override;
- bool RunsTasksOnCurrentThread() const override;
-
- // Overridden from cc::TaskGraphRunner:
- cc::NamespaceToken GetNamespaceToken() override;
- void ScheduleTasks(cc::NamespaceToken token, cc::TaskGraph* graph) override;
- void WaitForTasksToFinishRunning(cc::NamespaceToken token) override;
- void CollectCompletedTasks(cc::NamespaceToken token,
- cc::Task::Vector* completed_tasks) override;
-
- // Runs a task from one of the provided categories. Categories listed first
- // have higher priority.
- void Run(const std::vector<cc::TaskCategory>& categories,
- base::ConditionVariable* has_ready_to_run_tasks_cv);
-
- void FlushForTesting();
-
- // Spawn |num_threads| number of threads and start running work on the
- // worker threads.
- void Start(int num_threads);
-
- // Finish running all the posted tasks (and nested task posted by those tasks)
- // of all the associated task runners.
- // Once all the tasks are executed the method blocks until the threads are
- // terminated.
- void Shutdown();
-
- cc::TaskGraphRunner* GetTaskGraphRunner() { return this; }
-
- // Create a new sequenced task graph runner.
- scoped_refptr<base::SequencedTaskRunner> CreateSequencedTaskRunner();
-
- protected:
- ~RasterWorkerPool() override;
-
- private:
- class RasterWorkerPoolSequencedTaskRunner;
- friend class RasterWorkerPoolSequencedTaskRunner;
-
- // Simple Task for the TaskGraphRunner that wraps a closure.
- // This class is used to schedule TaskRunner tasks on the
- // |task_graph_runner_|.
- class ClosureTask : public cc::Task {
- public:
- explicit ClosureTask(const base::Closure& closure);
-
- // Overridden from cc::Task:
- void RunOnWorkerThread() override;
-
- protected:
- ~ClosureTask() override;
-
- private:
- base::Closure closure_;
-
- DISALLOW_COPY_AND_ASSIGN(ClosureTask);
- };
-
- void ScheduleTasksWithLockAcquired(cc::NamespaceToken token,
- cc::TaskGraph* graph);
- void CollectCompletedTasksWithLockAcquired(cc::NamespaceToken token,
- cc::Task::Vector* completed_tasks);
-
- // Runs a task from one of the provided categories. Categories listed first
- // have higher priority. Returns false if there were no tasks to run.
- bool RunTaskWithLockAcquired(const std::vector<cc::TaskCategory>& categories);
-
- // Run next task for the given category. Caller must acquire |lock_| prior to
- // calling this function and make sure at least one task is ready to run.
- void RunTaskInCategoryWithLockAcquired(cc::TaskCategory category);
-
- // Helper function which signals worker threads if tasks are ready to run.
- void SignalHasReadyToRunTasksWithLockAcquired();
-
- // Determines if we should run a new task for the given category. This factors
- // in whether a task is available and whether the count of running tasks is
- // low enough to start a new one.
- bool ShouldRunTaskForCategoryWithLockAcquired(cc::TaskCategory category);
-
- // The actual threads where work is done.
- std::vector<std::unique_ptr<base::SimpleThread>> threads_;
-
- // Lock to exclusively access all the following members that are used to
- // implement the TaskRunner and TaskGraphRunner interfaces.
- base::Lock lock_;
- // Stores the tasks to be run, sorted by priority.
- cc::TaskGraphWorkQueue work_queue_;
- // Namespace used to schedule tasks in the task graph runner.
- cc::NamespaceToken namespace_token_;
- // List of tasks currently queued up for execution.
- cc::Task::Vector tasks_;
- // Graph object used for scheduling tasks.
- cc::TaskGraph graph_;
- // Cached vector to avoid allocation when getting the list of complete
- // tasks.
- cc::Task::Vector completed_tasks_;
- // Condition variables for foreground and background tasks.
- base::ConditionVariable has_ready_to_run_foreground_tasks_cv_;
- base::ConditionVariable has_ready_to_run_background_tasks_cv_;
- // Condition variable that is waited on by origin threads until a namespace
- // has finished running all associated tasks.
- base::ConditionVariable has_namespaces_with_finished_running_tasks_cv_;
- // Set during shutdown. Tells Run() to return when no more tasks are pending.
- bool shutdown_;
-};
-
-} // namespace content
-
-#endif // CONTENT_RENDERER_RASTER_WORKER_POOL_H_
« no previous file with comments | « content/renderer/categorized_worker_pool_unittest.cc ('k') | content/renderer/raster_worker_pool.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698