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

Side by Side Diff: base/threading/sequenced_worker_pool.h

Issue 9401032: Make SequencedWorkerPool a TaskRunner (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Created 8 years, 10 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 | Annotate | Revision Log
« no previous file with comments | « base/task_runner_unittest.cc ('k') | base/threading/sequenced_worker_pool.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 (c) 2012 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2012 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 #ifndef BASE_THREADING_SEQUENCED_WORKER_POOL_H_ 5 #ifndef BASE_THREADING_SEQUENCED_WORKER_POOL_H_
6 #define BASE_THREADING_SEQUENCED_WORKER_POOL_H_ 6 #define BASE_THREADING_SEQUENCED_WORKER_POOL_H_
7 #pragma once 7 #pragma once
8 8
9 #include <string> 9 #include <string>
10 10
11 #include "base/base_export.h" 11 #include "base/base_export.h"
12 #include "base/basictypes.h" 12 #include "base/basictypes.h"
13 #include "base/callback_forward.h" 13 #include "base/callback_forward.h"
14 #include "base/memory/ref_counted.h" 14 #include "base/memory/ref_counted.h"
15 #include "base/task_runner.h"
15 16
16 namespace tracked_objects { 17 namespace tracked_objects {
17 class Location; 18 class Location;
18 } // namespace tracked_objects 19 } // namespace tracked_objects
19 20
20 namespace base { 21 namespace base {
21 22
22 namespace internal { 23 namespace internal {
23 class SequencedWorkerPoolInner; 24 class SequencedWorkerPoolInner;
24 } // namespace internal 25 } // namespace internal
(...skipping 103 matching lines...) Expand 10 before | Expand all | Expand 10 after
128 // Returns a unique token that can be used to sequence tasks posted to 129 // Returns a unique token that can be used to sequence tasks posted to
129 // PostSequencedWorkerTask(). Valid tokens are alwys nonzero. 130 // PostSequencedWorkerTask(). Valid tokens are alwys nonzero.
130 SequenceToken GetSequenceToken(); 131 SequenceToken GetSequenceToken();
131 132
132 // Returns the sequence token associated with the given name. Calling this 133 // Returns the sequence token associated with the given name. Calling this
133 // function multiple times with the same string will always produce the 134 // function multiple times with the same string will always produce the
134 // same sequence token. If the name has not been used before, a new token 135 // same sequence token. If the name has not been used before, a new token
135 // will be created. 136 // will be created.
136 SequenceToken GetNamedSequenceToken(const std::string& name); 137 SequenceToken GetNamedSequenceToken(const std::string& name);
137 138
139 // Returns a TaskRunner which posts (unseqenced) tasks on this
willchan no longer on Chromium 2012/02/19 06:37:01 unsequenced
akalin 2012/02/22 22:39:11 Rendered moot (since this function doesn't exist a
140 // worker pool with BLOCK_SHUTDOWN.
141 scoped_refptr<TaskRunner> GetTaskRunner();
142
138 // Posts the given task for execution in the worker pool. Tasks posted with 143 // Posts the given task for execution in the worker pool. Tasks posted with
139 // this function will execute in an unspecified order on a background thread. 144 // this function will execute in an unspecified order on a background thread.
140 // Returns true if the task was posted. If your tasks have ordering 145 // Returns true if the task was posted. If your tasks have ordering
141 // requirements, see PostSequencedWorkerTask(). 146 // requirements, see PostSequencedWorkerTask().
142 // 147 //
143 // This class will attempt to delete tasks that aren't run 148 // This class will attempt to delete tasks that aren't run
144 // (non-block-shutdown semantics) but can't guarantee that this happens. If 149 // (non-block-shutdown semantics) but can't guarantee that this happens. If
145 // all worker threads are busy running CONTINUE_ON_SHUTDOWN tasks, there 150 // all worker threads are busy running CONTINUE_ON_SHUTDOWN tasks, there
146 // will be no workers available to delete these tasks. And there may be 151 // will be no workers available to delete these tasks. And there may be
147 // tasks with the same sequence token behind those CONTINUE_ON_SHUTDOWN 152 // tasks with the same sequence token behind those CONTINUE_ON_SHUTDOWN
(...skipping 66 matching lines...) Expand 10 before | Expand all | Expand 10 after
214 219
215 private: 220 private:
216 scoped_refptr<internal::SequencedWorkerPoolInner> inner_; 221 scoped_refptr<internal::SequencedWorkerPoolInner> inner_;
217 222
218 DISALLOW_COPY_AND_ASSIGN(SequencedWorkerPool); 223 DISALLOW_COPY_AND_ASSIGN(SequencedWorkerPool);
219 }; 224 };
220 225
221 } // namespace base 226 } // namespace base
222 227
223 #endif // BASE_THREADING_SEQUENCED_WORKER_POOL_H_ 228 #endif // BASE_THREADING_SEQUENCED_WORKER_POOL_H_
OLDNEW
« no previous file with comments | « base/task_runner_unittest.cc ('k') | base/threading/sequenced_worker_pool.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698