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

Side by Side Diff: base/threading/sequenced_task_runner_handle.cc

Issue 2867693004: Snapshot of all changes to get jumbo in blink and content.
Patch Set: Rebased again Created 3 years, 5 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 unified diff | Download patch
« no previous file with comments | « base/task_scheduler/post_task.cc ('k') | base/trace_event/trace_log.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright 2015 The Chromium Authors. All rights reserved. 1 // Copyright 2015 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #include "base/threading/sequenced_task_runner_handle.h" 5 #include "base/threading/sequenced_task_runner_handle.h"
6 6
7 #include <utility> 7 #include <utility>
8 8
9 #include "base/lazy_instance.h" 9 #include "base/lazy_instance.h"
10 #include "base/logging.h" 10 #include "base/logging.h"
11 #include "base/threading/sequenced_worker_pool.h" 11 #include "base/threading/sequenced_worker_pool.h"
12 #include "base/threading/thread_local.h" 12 #include "base/threading/thread_local.h"
13 #include "base/threading/thread_task_runner_handle.h" 13 #include "base/threading/thread_task_runner_handle.h"
14 14
15 namespace base { 15 namespace base {
16 16
17 namespace { 17 namespace {
18 18
19 LazyInstance<ThreadLocalPointer<SequencedTaskRunnerHandle>>::Leaky 19 LazyInstance<ThreadLocalPointer<SequencedTaskRunnerHandle>>::Leaky
20 lazy_tls_ptr = LAZY_INSTANCE_INITIALIZER; 20 lazy_tls_strh_ptr = LAZY_INSTANCE_INITIALIZER;
21 21
22 } // namespace 22 } // namespace
23 23
24 // static 24 // static
25 scoped_refptr<SequencedTaskRunner> SequencedTaskRunnerHandle::Get() { 25 scoped_refptr<SequencedTaskRunner> SequencedTaskRunnerHandle::Get() {
26 // Return the registered SingleThreadTaskRunner, if any. This must be at the 26 // Return the registered SingleThreadTaskRunner, if any. This must be at the
27 // top so that a SingleThreadTaskRunner has priority over a 27 // top so that a SingleThreadTaskRunner has priority over a
28 // SequencedTaskRunner (RLZ registers both on the same thread despite that 28 // SequencedTaskRunner (RLZ registers both on the same thread despite that
29 // being prevented by DCHECKs). 29 // being prevented by DCHECKs).
30 // TODO(fdoray): Move this to the bottom once RLZ stops registering a 30 // TODO(fdoray): Move this to the bottom once RLZ stops registering a
31 // SingleThreadTaskRunner and a SequencedTaskRunner on the same thread. 31 // SingleThreadTaskRunner and a SequencedTaskRunner on the same thread.
32 // https://crbug.com/618530#c14 32 // https://crbug.com/618530#c14
33 if (ThreadTaskRunnerHandle::IsSet()) { 33 if (ThreadTaskRunnerHandle::IsSet()) {
34 // Various modes of setting SequencedTaskRunnerHandle don't combine. 34 // Various modes of setting SequencedTaskRunnerHandle don't combine.
35 DCHECK(!lazy_tls_ptr.Pointer()->Get()); 35 DCHECK(!lazy_tls_strh_ptr.Pointer()->Get());
36 DCHECK(!SequencedWorkerPool::GetSequenceTokenForCurrentThread().IsValid()); 36 DCHECK(!SequencedWorkerPool::GetSequenceTokenForCurrentThread().IsValid());
37 37
38 return ThreadTaskRunnerHandle::Get(); 38 return ThreadTaskRunnerHandle::Get();
39 } 39 }
40 40
41 // Return the registered SequencedTaskRunner, if any. 41 // Return the registered SequencedTaskRunner, if any.
42 const SequencedTaskRunnerHandle* handle = lazy_tls_ptr.Pointer()->Get(); 42 const SequencedTaskRunnerHandle* handle = lazy_tls_strh_ptr.Pointer()->Get();
43 if (handle) { 43 if (handle) {
44 // Various modes of setting SequencedTaskRunnerHandle don't combine. 44 // Various modes of setting SequencedTaskRunnerHandle don't combine.
45 DCHECK(!SequencedWorkerPool::GetSequenceTokenForCurrentThread().IsValid()); 45 DCHECK(!SequencedWorkerPool::GetSequenceTokenForCurrentThread().IsValid());
46 46
47 return handle->task_runner_; 47 return handle->task_runner_;
48 } 48 }
49 49
50 // If we are on a worker thread for a SequencedBlockingPool that is running a 50 // If we are on a worker thread for a SequencedBlockingPool that is running a
51 // sequenced task, return a SequencedTaskRunner for it. 51 // sequenced task, return a SequencedTaskRunner for it.
52 scoped_refptr<SequencedWorkerPool> pool = 52 scoped_refptr<SequencedWorkerPool> pool =
53 SequencedWorkerPool::GetWorkerPoolForCurrentThread(); 53 SequencedWorkerPool::GetWorkerPoolForCurrentThread();
54 DCHECK(pool); 54 DCHECK(pool);
55 SequencedWorkerPool::SequenceToken sequence_token = 55 SequencedWorkerPool::SequenceToken sequence_token =
56 SequencedWorkerPool::GetSequenceTokenForCurrentThread(); 56 SequencedWorkerPool::GetSequenceTokenForCurrentThread();
57 DCHECK(sequence_token.IsValid()); 57 DCHECK(sequence_token.IsValid());
58 scoped_refptr<SequencedTaskRunner> sequenced_task_runner( 58 scoped_refptr<SequencedTaskRunner> sequenced_task_runner(
59 pool->GetSequencedTaskRunner(sequence_token)); 59 pool->GetSequencedTaskRunner(sequence_token));
60 DCHECK(sequenced_task_runner->RunsTasksOnCurrentThread()); 60 DCHECK(sequenced_task_runner->RunsTasksOnCurrentThread());
61 return sequenced_task_runner; 61 return sequenced_task_runner;
62 } 62 }
63 63
64 // static 64 // static
65 bool SequencedTaskRunnerHandle::IsSet() { 65 bool SequencedTaskRunnerHandle::IsSet() {
66 return lazy_tls_ptr.Pointer()->Get() || 66 return lazy_tls_strh_ptr.Pointer()->Get() ||
67 SequencedWorkerPool::GetSequenceTokenForCurrentThread().IsValid() || 67 SequencedWorkerPool::GetSequenceTokenForCurrentThread().IsValid() ||
68 ThreadTaskRunnerHandle::IsSet(); 68 ThreadTaskRunnerHandle::IsSet();
69 } 69 }
70 70
71 SequencedTaskRunnerHandle::SequencedTaskRunnerHandle( 71 SequencedTaskRunnerHandle::SequencedTaskRunnerHandle(
72 scoped_refptr<SequencedTaskRunner> task_runner) 72 scoped_refptr<SequencedTaskRunner> task_runner)
73 : task_runner_(std::move(task_runner)) { 73 : task_runner_(std::move(task_runner)) {
74 DCHECK(task_runner_->RunsTasksOnCurrentThread()); 74 DCHECK(task_runner_->RunsTasksOnCurrentThread());
75 DCHECK(!SequencedTaskRunnerHandle::IsSet()); 75 DCHECK(!SequencedTaskRunnerHandle::IsSet());
76 lazy_tls_ptr.Pointer()->Set(this); 76 lazy_tls_strh_ptr.Pointer()->Set(this);
77 } 77 }
78 78
79 SequencedTaskRunnerHandle::~SequencedTaskRunnerHandle() { 79 SequencedTaskRunnerHandle::~SequencedTaskRunnerHandle() {
80 DCHECK(task_runner_->RunsTasksOnCurrentThread()); 80 DCHECK(task_runner_->RunsTasksOnCurrentThread());
81 DCHECK_EQ(lazy_tls_ptr.Pointer()->Get(), this); 81 DCHECK_EQ(lazy_tls_strh_ptr.Pointer()->Get(), this);
82 lazy_tls_ptr.Pointer()->Set(nullptr); 82 lazy_tls_strh_ptr.Pointer()->Set(nullptr);
83 } 83 }
84 84
85 } // namespace base 85 } // namespace base
OLDNEW
« no previous file with comments | « base/task_scheduler/post_task.cc ('k') | base/trace_event/trace_log.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698