| /external/drm_hwcomposer/ |
| drmeventlistener.h | 21 #include "worker.h"
37 class DrmEventListener : public Worker {
|
| virtualcompositorworker.h | 21 #include "worker.h"
27 class VirtualCompositorWorker : public Worker {
|
| vsyncworker.h | 21 #include "worker.h"
31 class VSyncWorker : public Worker {
|
| drmcompositorworker.cpp | 17 #define LOG_TAG "hwc-drm-compositor-worker"
21 #include "worker.h"
33 : Worker("drm-compositor", HAL_PRIORITY_URGENT_DISPLAY),
49 ALOGE("Failed to lock worker, %d", ret);
61 ALOGE("Failed to unlock worker, %d", ret);
|
| /external/opencv3/samples/gpu/ |
| multi.cpp | 47 struct Worker { void operator()(int device_id) const; };
73 tbb::parallel_do(devices, devices + 2, Worker());
79 void Worker::operator()(int device_id) const
|
| driver_api_multi.cpp | 54 struct Worker { void operator()(int device_id) const; };
114 tbb::parallel_do(devices, devices + 2, Worker());
121 void Worker::operator()(int device_id) const
|
| driver_api_stereo_multi.cpp | 56 struct Worker { void operator()(int device_id) const; };
177 tbb::parallel_do(devices, devices + 2, Worker());
203 void Worker::operator()(int device_id) const
|
| /external/valgrind/none/tests/darwin/ |
| bug228343.c | 35 void *Worker() {
53 pthread_create(&w_1, NULL, Worker, NULL);
54 pthread_create(&w_2, NULL, Worker, NULL);
|
| /external/valgrind/drd/tests/ |
| tsan_unittest.cpp | 335 void Worker() {
340 MyThread t(Worker);
643 // Parent: Worker:
645 // 2. Start(Worker) ------------>
647 // 3. Join(Worker) <------------
649 void Worker() {
654 MyThread t(Worker);
749 void Worker() {
762 MyThreadArray t(Worker, Worker);
[all...] |
| /external/webrtc/webrtc/base/ |
| signalthread.cc | 108 // Before signaling that the work is done, make sure that the worker
110 // Run() posted the ST_MSG_WORKER_DONE message. This means the worker
115 // Calling Stop() on the worker ensures that the OS thread that underlies
116 // the worker will finish, and will be set to NULL, enabling us to call
127 SignalThread::Worker::~Worker() {
131 void SignalThread::Worker::Run() {
|
| /external/caliper/caliper/src/main/java/com/google/caliper/worker/ |
| Worker.java | 16 package com.google.caliper.worker;
28 * A {@link Worker} collects measurements on behalf of a particular Instrument.
30 public abstract class Worker {
42 protected Worker(Object benchmark, Method method) {
|
| MacrobenchmarkAllocationWorker.java | 17 package com.google.caliper.worker;
29 * The {@link Worker} for the {@code AllocationInstrument}. This class invokes the benchmark method
33 public final class MacrobenchmarkAllocationWorker extends Worker {
|
| /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");
|
| /packages/apps/Settings/src/com/android/settings/dashboard/ |
| SummaryLoader.java | 49 private final Worker mWorker;
62 mWorker = new Worker(mWorkerThread.getLooper());
68 mWorker.obtainMessage(Worker.MSG_GET_PROVIDER, tile).sendToTarget();
110 mWorker.removeMessages(Worker.MSG_SET_LISTENING);
111 mWorker.obtainMessage(Worker.MSG_SET_LISTENING, listening ? 1 : 0, 0).sendToTarget();
198 private class Worker extends Handler {
202 public Worker(Looper looper) {
|
| /cts/tests/openglperf2/src/android/opengl2/cts/reference/ |
| GLGameActivity.java | 75 // Spawns a worker.
76 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/libchrome/base/threading/ |
| sequenced_worker_pool.cc | 227 // Worker ---------------------------------------------------------------------
229 class SequencedWorkerPool::Worker : public SimpleThread {
233 Worker(const scoped_refptr<SequencedWorkerPool>& worker_pool,
236 ~Worker() override;
241 // Gets the worker for the current thread out of thread-local storage.
242 static Worker* GetForCurrentThread();
256 // Whether the worker is processing a task.
274 static LazyInstance<ThreadLocalPointer<SequencedWorkerPool::Worker>>::Leaky
284 // Whether the Worker is processing a task.
287 DISALLOW_COPY_AND_ASSIGN(Worker);
1212 Worker* worker = Worker::GetForCurrentThread(); local
1222 Worker* worker = Worker::GetForCurrentThread(); local
1232 Worker* worker = Worker::GetForCurrentThread(); local
[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) {
|
| /external/v8/test/mjsunit/ |
| d8-worker-spawn-worker.js | 28 if (this.Worker) {
30 `var w = new Worker('postMessage(42)');
37 var w = new Worker(workerScript);
|
| d8-worker-sharedarraybuffer.js | 30 if (this.Worker) {
49 var w = new Worker(workerScript);
61 // Spinwait for the worker to update ta[0]
88 workers[id] = new Worker(workerScript);
92 // Spinwait for each worker to update ta[id]
97 // Worker is finished.
|
| d8-worker.js | 28 // Test the Worker API of d8. This test only makes sense with d8. A Worker
33 `postMessage('Starting worker');
34 // Set a global variable; should not be visible outside of the worker's
92 if (this.Worker) {
101 var w = new Worker(workerScript);
103 assertEquals("Starting worker", w.getMessage());
126 // Read a message from the worker.
133 // the worker dies without posting a message.
134 var w2 = new Worker('');
[all...] |
| /libcore/luni/src/main/java/java/util/concurrent/ |
| ThreadPoolExecutor.java | 61 * created to handle the request, even if other worker threads are
95 * worker threads or other threads using the pool do not possess this
236 * internal worker threads may in turn fail, abruptly terminate, and
424 * The queue used for holding tasks and handing off to worker
452 * Set containing all worker threads in pool. Accessed only when
455 private final HashSet<Worker> workers = new HashSet<>();
470 * worker threads. Accessed only under mainLock.
542 * have permission to actually interrupt threads in the worker set
563 * Class Worker mainly maintains interrupt control state for
568 * intended to wake up a worker thread waiting for a task fro
[all...] |
| /cts/tests/openglperf2/src/android/opengl2/cts/primitive/ |
| GLPrimitiveActivity.java | 79 // Spawns a worker to run the benchmark.
80 Worker worker = new Worker(); local
81 worker.start();
114 private class Worker extends Thread implements WatchDog.TimeoutCallback {
|
| /external/v8/test/mjsunit/harmony/ |
| futex.js | 100 //// WORKER ONLY TESTS
102 if (this.Worker) {
115 var worker = new Worker(workerScript);
116 worker.postMessage({sab: sab, offset: offset}, [sab]);
118 // Spin until the worker is waiting on the futex.
122 assertEquals(Atomics.OK, worker.getMessage());
123 worker.terminate();
125 var worker2 = new Worker(workerScript);
130 // Spin until the worker is waiting on the futex
[all...] |
| /external/llvm/lib/Support/ |
| ThreadPool.cpp | 106 for (auto &Worker : Threads)
107 Worker.join();
|
| /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...] |
