| Index: components/scheduler/promises/single_thread_promise_executor.cc
|
| diff --git a/components/scheduler/promises/single_thread_promise_executor.cc b/components/scheduler/promises/single_thread_promise_executor.cc
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..be36812c3d52c9a0a8cd72e5ae98029541e29074
|
| --- /dev/null
|
| +++ b/components/scheduler/promises/single_thread_promise_executor.cc
|
| @@ -0,0 +1,49 @@
|
| +// 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.
|
| +
|
| +#include "components/scheduler/promises/single_thread_promise_executor.h"
|
| +
|
| +#include "base/bind.h"
|
| +
|
| +namespace promise {
|
| +namespace internal {
|
| +
|
| +SingleThreadPromiseExecutor::SingleThreadPromiseExecutor(
|
| + const scoped_refptr<base::SingleThreadTaskRunner>& task_runner)
|
| + : task_runner_(task_runner) {}
|
| +
|
| +SingleThreadPromiseExecutor::~SingleThreadPromiseExecutor() {}
|
| +
|
| +void SingleThreadPromiseExecutor::StartResolveInternal(PromiseBase* promise) {
|
| + PromiseExecutor::StartResolveInternal(promise);
|
| + DispatchResolveImpl();
|
| +}
|
| +
|
| +void SingleThreadPromiseExecutor::ResolveImpl() {
|
| + PromiseBase* ready_promise = GetNextReadyPromise();
|
| + if (!ready_promise)
|
| + return;
|
| + ResolvePromise(ready_promise);
|
| +}
|
| +
|
| +void SingleThreadPromiseExecutor::DispatchResolveImpl() {
|
| + task_runner_->PostTask(FROM_HERE,
|
| + base::Bind(&SingleThreadPromiseExecutor::ResolveImpl,
|
| + base::Unretained(this)));
|
| +}
|
| +
|
| +bool SingleThreadPromiseExecutor::OnPromiseResolved(PromiseBase* promise) {
|
| + if (PromiseExecutor::OnPromiseResolved(promise))
|
| + DispatchResolveImpl();
|
| + return false;
|
| +}
|
| +
|
| +bool SingleThreadPromiseExecutor::OnPromiseRejected(PromiseBase* promise) {
|
| + if (PromiseExecutor::OnPromiseRejected(promise))
|
| + DispatchResolveImpl();
|
| + return false;
|
| +}
|
| +
|
| +} // namespace internal
|
| +} // namespace promise
|
|
|