| /external/chromium_org/third_party/WebKit/Source/web/ |
| WorkerGlobalScopeProxyProviderImpl.cpp | 42 #include "core/workers/Worker.h"
53 WebCore::WorkerGlobalScopeProxy* WorkerGlobalScopeProxyProviderImpl::createWorkerGlobalScopeProxy(Worker* worker)
55 if (worker->executionContext()->isDocument()) {
56 Document* document = toDocument(worker->executionContext());
62 return new WorkerMessagingProxy(worker, workerClients.release());
|
| /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/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...] |
| image_loader.js | 21 * @type {Worker}
24 this.worker_ = new Worker();
81 // Create a request task and add it to the worker (queue).
|
| /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/Source/bindings/v8/custom/ |
| V8WorkerCustom.cpp | 39 #include "core/workers/Worker.h"
47 ExceptionState exceptionState(ExceptionState::ExecutionContext, "postMessage", "Worker", info.Holder(), info.GetIsolate());
48 Worker* worker = V8Worker::toNative(info.Holder()); local
66 worker->postMessage(message.release(), &ports, exceptionState);
|
| /external/valgrind/unittest/ |
| 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...] |
| demo_tests.cc | 76 void Worker() {
104 MyThread t1(Worker), t2(Worker);
474 void Worker() { Func19(); }
477 MyThreadArray t(Worker, Worker, Worker);
488 // Worker(N) will do 2^N increments of GLOB, each increment in a separate thread
489 void Worker(int depth) {
494 pool.Add(NewCallback(Worker, depth-1))
[all...] |
| thread_wrappers.h | 237 MyThread *thread = new MyThread(&ThreadPool::Worker, this);
270 static void *Worker(void *p) {
|
| windows_tests.cc | 492 void Worker() {
498 MyThreadArray mta(Worker, Worker);
|
| /libcore/luni/src/main/java/java/util/concurrent/ |
| ThreadPoolExecutor.java | 55 * created to handle the request, even if other worker threads are
218 * <p>If hook or callback methods throw exceptions, internal worker
404 * The queue used for holding tasks and handing off to worker
432 * Set containing all worker threads in pool. Accessed only when
435 private final HashSet<Worker> workers = new HashSet<Worker>();
450 * worker threads. Accessed only under mainLock.
522 * have permission to actually interrupt threads in the worker set
543 * Class Worker mainly maintains interrupt control state for
548 * intended to wake up a worker thread waiting for a task fro
[all...] |
| /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) {
|
| /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 {
|
| /external/chromium_org/content/test/data/workers/ |
| worker_utils.js | 4 // Create either a dedicated or shared worker, depending on flags
7 // Make a shared worker that looks like a worker
8 var worker = new SharedWorker(worker_url, "name" + ++shared_worker_count);
9 worker.port.onmessage = function(evt) {
10 worker.onmessage(evt);
12 worker.postMessage = function(msg, port) {
13 worker.port.postMessage(msg, port);
15 return worker;
17 return new Worker(worker_url)
[all...] |
| /frameworks/base/tests/CoreTests/android/core/ |
| TestWebServer.java | 41 /* Where worker threads stand idle */
44 /* List of all active worker threads */
50 /* max # worker threads */
216 * The AcceptThread is responsible for initiating worker threads
263 Worker w = null;
266 Worker ws = new Worker();
269 (new Thread(ws, "additional worker")).start();
271 w = (Worker) threads.elementAt(0);
298 // Stop worker threads from continuin
[all...] |
| /packages/services/Telephony/src/com/android/phone/ |
| Ringer.java | 65 private Worker mRingThread;
261 private class Worker implements Runnable {
265 Worker(String name) {
309 mRingThread = new Worker("ringer");
|
| /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...] |
| sequenced_worker_pool.h | 30 // A worker thread pool that enforces ordering between sets of tasks. It also
66 // not enforce shutdown semantics or allow us to specify how many worker
77 // Defines what should happen to a task posted to the worker pool on
82 // shutdown will be ignored (the worker thread will not be joined).
121 // Opaque identifier that defines sequencing of tasks posted to the worker
155 // If current thread is not a SequencedWorkerPool worker thread or is running
206 // Posts the given task for execution in the worker pool. Tasks posted with
213 // all worker threads are busy running CONTINUE_ON_SHUTDOWN tasks, there
316 // Implements the worker pool shutdown. This should be called during app
348 class Worker;
[all...] |
| /external/apache-harmony/luni/src/test/api/common/org/apache/harmony/luni/tests/java/io/ |
| PipedInputStreamTest.java | 355 static class Worker extends Thread {
358 Worker(PipedOutputStream pos) {
376 Thread worker = new Worker(out); local
377 worker.start();
380 worker.join();
|
| /external/clang/test/FixIt/ |
| fixit.cpp | 236 class Worker {
242 wrapped_ptr<Worker> worker(new Worker);
243 worker.DoSomething(); // expected-error {{no member named 'DoSomething' in 'arrow_suggest::wrapped_ptr<arrow_suggest::Worker>'; did you mean to use '->' instead of '.'?}}
|
| /external/chromium_org/content/browser/devtools/ |
| devtools_protocol_constants.cc | 278 namespace Worker {
279 const char kName[] = "Worker";
282 const char kName[] = "Worker.disconnectFromWorker";
287 const char kName[] = "Worker.disconnectedFromWorker";
289 } // Worker
|
| devtools_protocol_constants.h | 279 namespace Worker {
290 } // Worker
|
| /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");
|
| ScriptFormatter.js | 122 * @return {!Worker}
127 this._cachedWorker = new Worker("ScriptFormatterWorker.js");
128 this._cachedWorker.onmessage = /** @type {function(this:Worker)} */ (this._didFormatContent.bind(this));
|
| /libcore/support/src/test/java/tests/support/ |
| Support_TestWebServer.java | 214 * The AcceptThread is responsible for initiating worker threads
245 new Thread(new Worker(s), "additional worker").start();
302 * The worker thread handles all interactions with a current open
307 class Worker implements Support_HttpConstants, Runnable {
336 /* Create a new worker thread */
337 Worker(Socket s) {
|
