Index: third_party/WebKit/Source/platform/scheduler/child/worker_scheduler.cc |
diff --git a/third_party/WebKit/Source/platform/scheduler/child/worker_scheduler.cc b/third_party/WebKit/Source/platform/scheduler/child/worker_scheduler.cc |
index 1bddca0a91d1dcad3f3bed554309e42547a41dff..d3ca3a9c7f017b8d65a839a60b96b86c46fe11e1 100644 |
--- a/third_party/WebKit/Source/platform/scheduler/child/worker_scheduler.cc |
+++ b/third_party/WebKit/Source/platform/scheduler/child/worker_scheduler.cc |
@@ -14,7 +14,8 @@ |
namespace blink { |
namespace scheduler { |
-WorkerScheduler::WorkerScheduler() {} |
+WorkerScheduler::WorkerScheduler(std::unique_ptr<SchedulerHelper> helper) |
+ : helper_(std::move(helper)) {} |
WorkerScheduler::~WorkerScheduler() {} |
@@ -24,5 +25,15 @@ std::unique_ptr<WorkerScheduler> WorkerScheduler::Create( |
return base::WrapUnique(new WorkerSchedulerImpl(std::move(main_task_runner))); |
} |
+scoped_refptr<TaskQueue> WorkerScheduler::CreateUnthrottledTaskRunner( |
+ TaskQueue::QueueType queue_type) { |
+ helper_->CheckOnValidThread(); |
+ scoped_refptr<TaskQueue> unthrottled_task_queue( |
+ helper_->NewTaskQueue(TaskQueue::Spec(queue_type) |
+ .SetShouldMonitorQuiescence(true) |
+ .SetTimeDomain(nullptr))); |
+ return unthrottled_task_queue; |
+} |
+ |
} // namespace scheduler |
} // namespace blink |