Commit 460295fd authored by Minoru Chikamune's avatar Minoru Chikamune Committed by Commit Bot

[MBI] Remove CleanupTaskRunner

We are going to remove cleanup_task_queue and cleanup_task_runner. The scheduling policy of cleanup_task_queue is the same as the default task queue. We can simply use the (per-isolate) default task queue instead of cleanup_task_queue.

[related design doc section]
https://docs.google.com/document/d/1y-vHkrD1z2RtyWYwT6rJkSLHClYNjDDpUbTtBU7l95A/edit#bookmark=id.i19urefmv8te

Bug: 1105403
Change-Id: I3cd4ddac6f4b44fcb3d9105fd826777246c70131
Reviewed-on: https://chromium-review.googlesource.com/c/chromium/src/+/2335847Reviewed-by: default avatarKouhei Ueno <kouhei@chromium.org>
Reviewed-by: default avatarKentaro Hara <haraken@chromium.org>
Reviewed-by: default avatarAlexander Timin <altimin@chromium.org>
Commit-Queue: Minoru Chikamune <chikamune@chromium.org>
Cr-Commit-Position: refs/heads/master@{#794782}
parent 32718882
...@@ -82,9 +82,6 @@ class BLINK_PLATFORM_EXPORT WebThreadScheduler { ...@@ -82,9 +82,6 @@ class BLINK_PLATFORM_EXPORT WebThreadScheduler {
virtual scoped_refptr<base::SingleThreadTaskRunner> IPCTaskRunner(); virtual scoped_refptr<base::SingleThreadTaskRunner> IPCTaskRunner();
// Returns the cleanup task runner, which is for cleaning up.
virtual scoped_refptr<base::SingleThreadTaskRunner> CleanupTaskRunner();
// Returns a default task runner. This is basically same as the default task // Returns a default task runner. This is basically same as the default task
// runner, but is explicitly allowed to run JavaScript. For the detail, see // runner, but is explicitly allowed to run JavaScript. For the detail, see
// the comment at blink::ThreadScheduler::DeprecatedDefaultTaskRunner. // the comment at blink::ThreadScheduler::DeprecatedDefaultTaskRunner.
......
...@@ -260,7 +260,8 @@ enum class TaskType : unsigned char { ...@@ -260,7 +260,8 @@ enum class TaskType : unsigned char {
kMainThreadTaskQueueIdle = 41, kMainThreadTaskQueueIdle = 41,
kMainThreadTaskQueueIPC = 42, kMainThreadTaskQueueIPC = 42,
kMainThreadTaskQueueControl = 43, kMainThreadTaskQueueControl = 43,
kMainThreadTaskQueueCleanup = 52, // Removed:
// kMainThreadTaskQueueCleanup = 52,
kMainThreadTaskQueueMemoryPurge = 62, kMainThreadTaskQueueMemoryPurge = 62,
kMainThreadTaskQueueNonWaking = 69, kMainThreadTaskQueueNonWaking = 69,
kCompositorThreadTaskQueueDefault = 45, kCompositorThreadTaskQueueDefault = 45,
......
...@@ -243,11 +243,6 @@ class DummyWebThreadScheduler : public WebThreadScheduler, ...@@ -243,11 +243,6 @@ class DummyWebThreadScheduler : public WebThreadScheduler,
return base::ThreadTaskRunnerHandle::Get(); return base::ThreadTaskRunnerHandle::Get();
} }
scoped_refptr<base::SingleThreadTaskRunner> CleanupTaskRunner() override {
DCHECK(WTF::IsMainThread());
return base::ThreadTaskRunnerHandle::Get();
}
scoped_refptr<base::SingleThreadTaskRunner> V8TaskRunner() override { scoped_refptr<base::SingleThreadTaskRunner> V8TaskRunner() override {
DCHECK(WTF::IsMainThread()); DCHECK(WTF::IsMainThread());
return base::ThreadTaskRunnerHandle::Get(); return base::ThreadTaskRunnerHandle::Get();
......
...@@ -78,12 +78,6 @@ WebThreadScheduler::IPCTaskRunner() { ...@@ -78,12 +78,6 @@ WebThreadScheduler::IPCTaskRunner() {
return nullptr; return nullptr;
} }
scoped_refptr<base::SingleThreadTaskRunner>
WebThreadScheduler::CleanupTaskRunner() {
NOTREACHED();
return nullptr;
}
scoped_refptr<base::SingleThreadTaskRunner> scoped_refptr<base::SingleThreadTaskRunner>
WebThreadScheduler::DeprecatedDefaultTaskRunner() { WebThreadScheduler::DeprecatedDefaultTaskRunner() {
NOTREACHED(); NOTREACHED();
......
...@@ -473,7 +473,6 @@ QueueTraits FrameSchedulerImpl::CreateQueueTraitsForTaskType(TaskType type) { ...@@ -473,7 +473,6 @@ QueueTraits FrameSchedulerImpl::CreateQueueTraitsForTaskType(TaskType type) {
case TaskType::kMainThreadTaskQueueIdle: case TaskType::kMainThreadTaskQueueIdle:
case TaskType::kMainThreadTaskQueueIPC: case TaskType::kMainThreadTaskQueueIPC:
case TaskType::kMainThreadTaskQueueControl: case TaskType::kMainThreadTaskQueueControl:
case TaskType::kMainThreadTaskQueueCleanup:
case TaskType::kMainThreadTaskQueueMemoryPurge: case TaskType::kMainThreadTaskQueueMemoryPurge:
case TaskType::kCompositorThreadTaskQueueDefault: case TaskType::kCompositorThreadTaskQueueDefault:
case TaskType::kCompositorThreadTaskQueueInput: case TaskType::kCompositorThreadTaskQueueInput:
......
...@@ -234,8 +234,6 @@ MainThreadSchedulerImpl::MainThreadSchedulerImpl( ...@@ -234,8 +234,6 @@ MainThreadSchedulerImpl::MainThreadSchedulerImpl(
MainThreadTaskQueue::QueueType::kV8)); MainThreadTaskQueue::QueueType::kV8));
ipc_task_queue_ = NewTaskQueue(MainThreadTaskQueue::QueueCreationParams( ipc_task_queue_ = NewTaskQueue(MainThreadTaskQueue::QueueCreationParams(
MainThreadTaskQueue::QueueType::kIPC)); MainThreadTaskQueue::QueueType::kIPC));
cleanup_task_queue_ = NewTaskQueue(MainThreadTaskQueue::QueueCreationParams(
MainThreadTaskQueue::QueueType::kCleanup));
non_waking_task_queue_ = non_waking_task_queue_ =
NewTaskQueue(MainThreadTaskQueue::QueueCreationParams( NewTaskQueue(MainThreadTaskQueue::QueueCreationParams(
MainThreadTaskQueue::QueueType::kNonWaking) MainThreadTaskQueue::QueueType::kNonWaking)
...@@ -249,8 +247,6 @@ MainThreadSchedulerImpl::MainThreadSchedulerImpl( ...@@ -249,8 +247,6 @@ MainThreadSchedulerImpl::MainThreadSchedulerImpl(
TaskType::kMainThreadTaskQueueControl); TaskType::kMainThreadTaskQueueControl);
ipc_task_runner_ = ipc_task_runner_ =
ipc_task_queue_->CreateTaskRunner(TaskType::kMainThreadTaskQueueIPC); ipc_task_queue_->CreateTaskRunner(TaskType::kMainThreadTaskQueueIPC);
cleanup_task_runner_ = cleanup_task_queue_->CreateTaskRunner(
TaskType::kMainThreadTaskQueueCleanup);
non_waking_task_runner_ = non_waking_task_queue_->CreateTaskRunner( non_waking_task_runner_ = non_waking_task_queue_->CreateTaskRunner(
TaskType::kMainThreadTaskQueueNonWaking); TaskType::kMainThreadTaskQueueNonWaking);
...@@ -659,11 +655,6 @@ MainThreadSchedulerImpl::IPCTaskRunner() { ...@@ -659,11 +655,6 @@ MainThreadSchedulerImpl::IPCTaskRunner() {
return ipc_task_runner_; return ipc_task_runner_;
} }
scoped_refptr<base::SingleThreadTaskRunner>
MainThreadSchedulerImpl::CleanupTaskRunner() {
return cleanup_task_runner_;
}
scoped_refptr<base::SingleThreadTaskRunner> scoped_refptr<base::SingleThreadTaskRunner>
MainThreadSchedulerImpl::DeprecatedDefaultTaskRunner() { MainThreadSchedulerImpl::DeprecatedDefaultTaskRunner() {
return helper_.DeprecatedDefaultTaskRunner(); return helper_.DeprecatedDefaultTaskRunner();
......
...@@ -161,7 +161,6 @@ class PLATFORM_EXPORT MainThreadSchedulerImpl ...@@ -161,7 +161,6 @@ class PLATFORM_EXPORT MainThreadSchedulerImpl
std::unique_ptr<WebWidgetScheduler> CreateWidgetScheduler() override; std::unique_ptr<WebWidgetScheduler> CreateWidgetScheduler() override;
// Note: this is also shared by the ThreadScheduler interface. // Note: this is also shared by the ThreadScheduler interface.
scoped_refptr<base::SingleThreadTaskRunner> IPCTaskRunner() override; scoped_refptr<base::SingleThreadTaskRunner> IPCTaskRunner() override;
scoped_refptr<base::SingleThreadTaskRunner> CleanupTaskRunner() override;
scoped_refptr<base::SingleThreadTaskRunner> NonWakingTaskRunner() override; scoped_refptr<base::SingleThreadTaskRunner> NonWakingTaskRunner() override;
scoped_refptr<base::SingleThreadTaskRunner> DeprecatedDefaultTaskRunner() scoped_refptr<base::SingleThreadTaskRunner> DeprecatedDefaultTaskRunner()
override; override;
...@@ -839,7 +838,6 @@ class PLATFORM_EXPORT MainThreadSchedulerImpl ...@@ -839,7 +838,6 @@ class PLATFORM_EXPORT MainThreadSchedulerImpl
scoped_refptr<MainThreadTaskQueue> v8_task_queue_; scoped_refptr<MainThreadTaskQueue> v8_task_queue_;
scoped_refptr<MainThreadTaskQueue> ipc_task_queue_; scoped_refptr<MainThreadTaskQueue> ipc_task_queue_;
scoped_refptr<MainThreadTaskQueue> cleanup_task_queue_;
scoped_refptr<MainThreadTaskQueue> memory_purge_task_queue_; scoped_refptr<MainThreadTaskQueue> memory_purge_task_queue_;
scoped_refptr<MainThreadTaskQueue> non_waking_task_queue_; scoped_refptr<MainThreadTaskQueue> non_waking_task_queue_;
...@@ -847,7 +845,6 @@ class PLATFORM_EXPORT MainThreadSchedulerImpl ...@@ -847,7 +845,6 @@ class PLATFORM_EXPORT MainThreadSchedulerImpl
scoped_refptr<base::SingleThreadTaskRunner> compositor_task_runner_; scoped_refptr<base::SingleThreadTaskRunner> compositor_task_runner_;
scoped_refptr<base::SingleThreadTaskRunner> control_task_runner_; scoped_refptr<base::SingleThreadTaskRunner> control_task_runner_;
scoped_refptr<base::SingleThreadTaskRunner> ipc_task_runner_; scoped_refptr<base::SingleThreadTaskRunner> ipc_task_runner_;
scoped_refptr<base::SingleThreadTaskRunner> cleanup_task_runner_;
scoped_refptr<base::SingleThreadTaskRunner> non_waking_task_runner_; scoped_refptr<base::SingleThreadTaskRunner> non_waking_task_runner_;
MemoryPurgeManager memory_purge_manager_; MemoryPurgeManager memory_purge_manager_;
......
...@@ -55,8 +55,6 @@ const char* MainThreadTaskQueue::NameForQueueType( ...@@ -55,8 +55,6 @@ const char* MainThreadTaskQueue::NameForQueueType(
return "input_tq"; return "input_tq";
case MainThreadTaskQueue::QueueType::kDetached: case MainThreadTaskQueue::QueueType::kDetached:
return "detached_tq"; return "detached_tq";
case MainThreadTaskQueue::QueueType::kCleanup:
return "cleanup_tq";
case MainThreadTaskQueue::QueueType::kOther: case MainThreadTaskQueue::QueueType::kOther:
return "other_tq"; return "other_tq";
case MainThreadTaskQueue::QueueType::kWebScheduling: case MainThreadTaskQueue::QueueType::kWebScheduling:
...@@ -93,7 +91,6 @@ bool MainThreadTaskQueue::IsPerFrameTaskQueue( ...@@ -93,7 +91,6 @@ bool MainThreadTaskQueue::IsPerFrameTaskQueue(
case MainThreadTaskQueue::QueueType::kIPC: case MainThreadTaskQueue::QueueType::kIPC:
case MainThreadTaskQueue::QueueType::kInput: case MainThreadTaskQueue::QueueType::kInput:
case MainThreadTaskQueue::QueueType::kDetached: case MainThreadTaskQueue::QueueType::kDetached:
case MainThreadTaskQueue::QueueType::kCleanup:
case MainThreadTaskQueue::QueueType::kNonWaking: case MainThreadTaskQueue::QueueType::kNonWaking:
case MainThreadTaskQueue::QueueType::kOther: case MainThreadTaskQueue::QueueType::kOther:
return false; return false;
...@@ -115,7 +112,6 @@ MainThreadTaskQueue::QueueClass MainThreadTaskQueue::QueueClassForQueueType( ...@@ -115,7 +112,6 @@ MainThreadTaskQueue::QueueClass MainThreadTaskQueue::QueueClassForQueueType(
case QueueType::kV8: case QueueType::kV8:
case QueueType::kIPC: case QueueType::kIPC:
case QueueType::kNonWaking: case QueueType::kNonWaking:
case QueueType::kCleanup:
return QueueClass::kNone; return QueueClass::kNone;
case QueueType::kFrameLoading: case QueueType::kFrameLoading:
case QueueType::kFrameLoadingControl: case QueueType::kFrameLoadingControl:
......
...@@ -71,8 +71,7 @@ class PLATFORM_EXPORT MainThreadTaskQueue ...@@ -71,8 +71,7 @@ class PLATFORM_EXPORT MainThreadTaskQueue
// TODO(altimin): Move to the top when histogram is renumbered. // TODO(altimin): Move to the top when histogram is renumbered.
kDetached = 19, kDetached = 19,
kCleanup = 20, // 20 : kCleanup, obsolete.
// 21 : kWebSchedulingUserInteraction, obsolete. // 21 : kWebSchedulingUserInteraction, obsolete.
// 22 : kWebSchedulingBestEffort, obsolete. // 22 : kWebSchedulingBestEffort, obsolete.
......
...@@ -105,8 +105,6 @@ const char* TaskTypeNames::TaskTypeToString(TaskType task_type) { ...@@ -105,8 +105,6 @@ const char* TaskTypeNames::TaskTypeToString(TaskType task_type) {
return "MainThreadTaskQueueIPC"; return "MainThreadTaskQueueIPC";
case TaskType::kMainThreadTaskQueueControl: case TaskType::kMainThreadTaskQueueControl:
return "MainThreadTaskQueueControl"; return "MainThreadTaskQueueControl";
case TaskType::kMainThreadTaskQueueCleanup:
return "MainThreadTaskQueueCleanup";
case TaskType::kMainThreadTaskQueueMemoryPurge: case TaskType::kMainThreadTaskQueueMemoryPurge:
return "MainThreadTaskQueueMemoryPurge"; return "MainThreadTaskQueueMemoryPurge";
case TaskType::kMainThreadTaskQueueNonWaking: case TaskType::kMainThreadTaskQueueNonWaking:
......
...@@ -32,10 +32,6 @@ class SimpleMockMainThreadScheduler : public WebMockThreadScheduler { ...@@ -32,10 +32,6 @@ class SimpleMockMainThreadScheduler : public WebMockThreadScheduler {
return base::ThreadTaskRunnerHandle::Get(); return base::ThreadTaskRunnerHandle::Get();
} }
scoped_refptr<base::SingleThreadTaskRunner> CleanupTaskRunner() override {
return base::ThreadTaskRunnerHandle::Get();
}
std::unique_ptr<Thread> CreateMainThread() override { std::unique_ptr<Thread> CreateMainThread() override {
return simple_thread_scheduler_->CreateMainThread(); return simple_thread_scheduler_->CreateMainThread();
} }
......
...@@ -196,7 +196,6 @@ scoped_refptr<base::SingleThreadTaskRunner> WorkerScheduler::GetTaskRunner( ...@@ -196,7 +196,6 @@ scoped_refptr<base::SingleThreadTaskRunner> WorkerScheduler::GetTaskRunner(
case TaskType::kMainThreadTaskQueueIdle: case TaskType::kMainThreadTaskQueueIdle:
case TaskType::kMainThreadTaskQueueIPC: case TaskType::kMainThreadTaskQueueIPC:
case TaskType::kMainThreadTaskQueueControl: case TaskType::kMainThreadTaskQueueControl:
case TaskType::kMainThreadTaskQueueCleanup:
case TaskType::kMainThreadTaskQueueMemoryPurge: case TaskType::kMainThreadTaskQueueMemoryPurge:
case TaskType::kMainThreadTaskQueueNonWaking: case TaskType::kMainThreadTaskQueueNonWaking:
case TaskType::kCompositorThreadTaskQueueDefault: case TaskType::kCompositorThreadTaskQueueDefault:
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment