| /external/chromium_org/chrome/browser/resources/image_loader/ |
| worker.js | 8 * Worker for requests. Fetches requests from a queue and processes them
11 function Worker() {
14 * cache, then they are processed immediately after starting the worker.
45 * If the worker has been started.
57 Worker.MAXIMUM_IN_PARALLEL = 5;
62 * processed immediately once the worker is started.
66 Worker.prototype.add = function(request) {
81 * Removes a request from the worker (if exists).
84 Worker.prototype.remove = function(requestId) {
105 Worker.prototype.start = function()
[all...] |
| /external/chromium_org/third_party/libjingle/source/talk/base/ |
| worker.h | 38 // A worker is an object that performs some specific long-lived task in an
44 // each other, and it is an error to call them while the worker is running on
46 // The destructor may not be called if the worker is currently running
49 class Worker : private MessageHandler {
51 Worker();
53 // Destroys this Worker, but it must have already been stopped via StopWork().
54 virtual ~Worker();
56 // Attaches the worker to the current thread and begins processing work if not
69 // Called on the worker thread to start working.
71 // Called on the worker thread when work has been signalled via HaveWork()
[all...] |
| worker.cc | 28 #include "talk/base/worker.h"
40 Worker::Worker() : worker_thread_(NULL) {}
42 Worker::~Worker() {
49 bool Worker::StartWork() {
66 bool Worker::StopWork() {
81 void Worker::HaveWork() {
86 void Worker::OnMessage(talk_base::Message *msg) {
|
| signalthread.h | 40 // SignalThread - Base class for worker threads. The main thread should call
43 // Cancellation: Call Release(true), to abort the worker thread.
62 // Context: Main Thread. Call before Start to change the worker's name.
65 // Context: Main Thread. Call before Start to change the worker's priority.
68 // Context: Main Thread. Call to begin the worker thread.
71 // Context: Main Thread. If the worker thread is not running, deletes the
72 // object immediately. Otherwise, asks the worker thread to abort processing,
73 // and schedules the object to be deleted once the worker exits.
78 // Context: Main Thread. If the worker thread is complete, deletes the
80 // the worker thread completes. SignalWorkDone will be signalled
91 Thread* worker() { return &worker_; } function in class:talk_base::SignalThread
[all...] |
| /external/chromium_org/third_party/WebKit/Source/core/workers/ |
| Worker.h | 49 class Worker : public AbstractWorker, public ScriptWrappable, private WorkerScriptLoaderClient {
51 static PassRefPtr<Worker> create(ScriptExecutionContext*, const String& url, ExceptionState&);
52 virtual ~Worker();
67 explicit Worker(ScriptExecutionContext*);
77 WorkerGlobalScopeProxy* m_contextProxy; // The proxy outlives the worker to perform thread shutdown.
|
| Worker.cpp | 29 #include "core/workers/Worker.h"
49 inline Worker::Worker(ScriptExecutionContext* context)
56 PassRefPtr<Worker> Worker::create(ScriptExecutionContext* context, const String& url, ExceptionState& es)
61 RefPtr<Worker> worker = adoptRef(new Worker(context)); local
63 worker->suspendIfNeeded();
65 KURL scriptURL = worker->resolveURL(url, es)
[all...] |
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/test/ |
| threaded_import_hangers.py | 21 class Worker(threading.Thread):
38 t = Worker(func, args)
|
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/test/ |
| threaded_import_hangers.py | 21 class Worker(threading.Thread):
38 t = Worker(func, args)
|
| /external/chromium_org/media/audio/ |
| fake_audio_consumer.cc | 22 class FakeAudioConsumer::Worker
23 : public base::RefCountedThreadSafe<FakeAudioConsumer::Worker> {
25 Worker(const scoped_refptr<base::MessageLoopProxy>& worker_loop,
33 friend class base::RefCountedThreadSafe<Worker>;
34 ~Worker();
36 // Initialize and start regular calls to DoRead() on the worker thread.
39 // Cancel any delayed callbacks to DoRead() in the worker loop's queue.
44 // the worker loop.
55 // Used to cancel any delayed tasks still inside the worker loop's queue.
60 DISALLOW_COPY_AND_ASSIGN(Worker);
[all...] |
| /external/chromium_org/content/browser/devtools/ |
| devtools_protocol_constants.h | 77 namespace Worker {
81 } // Worker
|
| devtools_protocol_constants.cc | 46 namespace Worker {
48 const char kName[] = "Worker.disconnectedFromWorker";
50 } // Worker
|
| /external/clang/test/SemaCXX/ |
| arrow-operator.cpp | 53 class Worker {
60 wrapped_ptr<Worker> worker(new Worker);
61 worker.DoSomething(); // expected-error {{no member named 'DoSomething' in 'arrow_suggest::wrapped_ptr<arrow_suggest::Worker>'; did you mean to use '->' instead of '.'?}}
62 worker.DoSamething(); // expected-error {{no member named 'DoSamething' in 'arrow_suggest::wrapped_ptr<arrow_suggest::Worker>'}}
63 worker.Chuck(); // expected-error {{no member named 'Chuck' in 'arrow_suggest::wrapped_ptr<arrow_suggest::Worker>'; did you mean 'Check'?}
[all...] |
| /external/valgrind/unittest/ |
| atomicity_tests.cc | 70 void Worker() {
82 MyThreadArray t(Worker, Worker);
129 void Worker() {
138 MyThreadArray t(Worker, Worker, Worker);
|
| posix_tests.cc | 73 void Worker() {
86 MyThreadArray t(Worker, Worker);
265 void Worker() {
318 MyThreadArray t(Worker, Worker, Worker);
356 void Worker() {
392 MyThreadArray t(Worker, Worker, Worker)
[all...] |
| thread_wrappers.h | 237 MyThread *thread = new MyThread(&ThreadPool::Worker, this);
270 static void *Worker(void *p) {
|
| /external/chromium_org/third_party/WebKit/Source/devtools/front_end/ |
| WorkersSidebarPane.js | 34 WebInspector.Worker = function(id, url, shared)
64 separator.textContent = WebInspector.UIString("Dedicated worker inspectors");
100 var item = this._workerListElement.createChild("div", "dedicated-worker-item");
|
| /external/chromium_org/chrome/browser/media/ |
| desktop_media_picker_model.cc | 90 class DesktopMediaPickerModel::Worker
93 Worker(base::WeakPtr<DesktopMediaPickerModel> model,
96 virtual ~Worker();
116 DISALLOW_COPY_AND_ASSIGN(Worker);
119 DesktopMediaPickerModel::Worker::Worker(
132 DesktopMediaPickerModel::Worker::~Worker() {}
134 void DesktopMediaPickerModel::Worker::Refresh(const gfx::Size& thumbnail_size) {
212 webrtc::SharedMemory* DesktopMediaPickerModel::Worker::CreateSharedMemory
[all...] |
| /external/chromium/third_party/libjingle/source/talk/base/ |
| signalthread.h | 39 // SignalThread - Base class for worker threads. The main thread should call
42 // Cancellation: Call Release(true), to abort the worker thread.
59 // Context: Main Thread. Call before Start to change the worker's name.
62 // Context: Main Thread. Call before Start to change the worker's priority.
65 // Context: Main Thread. Call to begin the worker thread.
68 // Context: Main Thread. If the worker thread is not running, deletes the
69 // object immediately. Otherwise, asks the worker thread to abort processing,
70 // and schedules the object to be deleted once the worker exits.
75 // Context: Main Thread. If the worker thread is complete, deletes the
77 // the worker thread completes. SignalWorkDone will be signalled
88 Thread* worker() { return &worker_; } function in class:talk_base::SignalThread
[all...] |
| /packages/apps/QuickSearchBox/src/com/android/quicksearchbox/util/ |
| SingleThreadNamedTaskExecutor.java | 38 mWorker = threadFactory.newThread(new Worker());
63 private class Worker implements Runnable {
68 if (!mClosed) Log.w(TAG, "Worker exited before close");
|
| /external/chromium_org/ppapi/native_client/tests/nacl_browser/manifest_file/ |
| pm_manifest_file_test.cc | 73 // A Worker object is associated with a single worker thread and a
74 // plugin instance (which may be associated with multiple Worker
77 // reference will be immediately handed off to its associated worker
82 // handler thread should no longer use the Worker*).
83 class Worker {
85 explicit Worker(MyInstance *instance);
87 // RunToCompletion should be invoked in the worker thread. It
89 // automatically unref the Worker object, so the worker threa
162 Worker *worker() { return worker_; } function in class:MyInstance
608 Worker *worker = reinterpret_cast<Worker *>(arg); local
[all...] |
| /cts/suite/cts/deviceTests/opengl/src/com/android/cts/opengl/primitive/ |
| GLPrimitiveActivity.java | 80 // Spawns a worker to run the benchmark.
81 Worker worker = new Worker(); local
82 worker.start();
122 private class Worker extends Thread implements WatchDog.TimeoutCallback {
|
| /cts/suite/cts/deviceTests/opengl/src/com/android/cts/opengl/reference/ |
| GLGameActivity.java | 76 // Spawns a worker.
77 Worker worker = new Worker(new Handler() { local
87 worker.start();
100 private class Worker extends Thread implements WatchDog.TimeoutCallback {
105 public Worker(Handler handler) {
|
| /external/chromium_org/third_party/WebKit/Tools/Scripts/webkitpy/layout_tests/controllers/ |
| layout_test_runner.py | 111 self._printer.write_update('Starting %s ...' % grammar.pluralize('worker', num_workers))
137 return Worker(worker_connection, results_directory, self._options)
196 class Worker(object):
332 worker = self
342 self.result = worker._run_single_test(driver, test_input, stop_when_done)
428 This is used when there's only one worker, to minimize the per-shard overhead."""
|
| /packages/apps/Gallery2/gallerycommon/src/com/android/gallery3d/util/ |
| ThreadPool.java | 98 Worker<T> w = new Worker<T>(job, listener);
107 private class Worker<T> implements Runnable, Future<T>, JobContext {
109 private static final String TAG = "Worker";
119 public Worker(Job<T> job, FutureListener<T> listener) {
|
| /external/chromium_org/base/threading/ |
| sequenced_worker_pool.cc | 227 // Worker ---------------------------------------------------------------------
229 class SequencedWorkerPool::Worker : public SimpleThread {
233 Worker(const scoped_refptr<SequencedWorkerPool>& worker_pool,
236 virtual ~Worker();
260 DISALLOW_COPY_AND_ASSIGN(Worker);
267 // Take a raw pointer to |worker| to avoid cycles (since we're owned
303 // Runs the worker loop on the background thread.
304 void ThreadLoop(Worker* this_worker);
329 // running on the currently executing worker thread. If invoked from a thread
405 // Condition variable that is waited on by worker threads until ne
[all...] |
