| /external/webrtc/webrtc/base/ |
| worker.h | 21 // A worker is an object that performs some specific long-lived task in an
27 // each other, and it is an error to call them while the worker is running on
29 // The destructor may not be called if the worker is currently running
32 class Worker : private MessageHandler {
34 Worker();
36 // Destroys this Worker, but it must have already been stopped via StopWork().
37 ~Worker() override;
39 // Attaches the worker to the current thread and begins processing work if not
52 // Called on the worker thread to start working.
54 // Called on the worker thread when work has been signalled via HaveWork()
[all...] |
| worker.cc | 11 #include "webrtc/base/worker.h"
23 Worker::Worker() : worker_thread_(NULL) {}
25 Worker::~Worker() {
32 bool Worker::StartWork() {
49 bool Worker::StopWork() {
64 void Worker::HaveWork() {
69 void Worker::OnMessage(rtc::Message *msg) {
|
| signalthread.h | 23 // SignalThread - Base class for worker threads. The main thread should call
26 // Cancellation: Call Release(true), to abort the worker thread.
45 // Context: Main Thread. Call before Start to change the worker's name.
48 // Context: Main Thread. Call to begin the worker thread.
51 // Context: Main Thread. If the worker thread is not running, deletes the
52 // object immediately. Otherwise, asks the worker thread to abort processing,
53 // and schedules the object to be deleted once the worker exits.
58 // Context: Main Thread. If the worker thread is complete, deletes the
60 // the worker thread completes. SignalWorkDone will be signalled.
71 Thread* worker() { return &worker_; function in class:rtc::SignalThread
[all...] |
| /external/drm_hwcomposer/ |
| worker.cpp | 17 #include "worker.h"
24 Worker::Worker(const char *name, int priority)
28 Worker::~Worker() {
32 int Worker::InitWorker() {
38 new std::thread(&Worker::InternalRoutine, this));
45 void Worker::Exit() {
56 int Worker::WaitForSignalOrExitLocked(int64_t max_nanoseconds) {
79 void Worker::InternalRoutine()
[all...] |
| worker.h | 30 class Worker {
49 Worker(const char *name, int priority);
50 virtual ~Worker();
|
| drmeventlistener.h | 21 #include "worker.h"
37 class DrmEventListener : public Worker {
|
| /external/caliper/caliper/src/main/java/com/google/caliper/worker/ |
| WorkerModule.java | 17 package com.google.caliper.worker;
37 * Binds classes necessary for the worker. Also manages the injection of {@link Param parameters}
40 * <p>TODO(gak): Ensure that each worker only has bindings for the objects it needs and not the
41 * objects required by different workers. (i.e. don't bind a Ticker if the worker is an allocation
42 * worker).
46 private final Class<? extends Worker> workerClass;
52 this.workerClass = workerSpec.workerClass.asSubclass(Worker.class);
65 Worker provideWorker(Map<Class<? extends Worker>, Provider<Worker>> availableWorkers)
[all...] |
| WorkerComponent.java | 17 package com.google.caliper.worker;
26 * Creates {@link Worker} for an {@link com.google.caliper.runner.Experiment}.
36 Worker getWorker();
|
| /packages/apps/Dialer/java/com/android/dialer/common/concurrent/ |
| DialerExecutorFactory.java | 21 import com.android.dialer.common.concurrent.DialerExecutor.Worker;
37 * @param worker a function executed on a worker thread which accepts an {@link InputT} and
48 @NonNull Worker<InputT, OutputT> worker);
53 * @param worker a function executed on a worker thread which accepts an {@link InputT} and
62 @NonNull Worker<InputT, OutputT> worker);
|
| DialerExecutors.java | 22 import com.android.dialer.common.concurrent.DialerExecutor.Worker;
61 * // Must be called in onCreate; don't use non-static or anonymous inner classes for worker!
62 * myExecutor = DialerExecutors.createUiTaskBuilder(fragmentManager, taskId, worker)
69 * private static class MyWorker implements Worker<MyInputType, MyOutputType> {
90 * // Don't use non-static or anonymous inner classes for worker!
91 * myExecutor = DialerExecutors.createNonUiTaskBuilder(worker)
98 * private static class MyWorker implements Worker<MyInputType, MyOutputType> {
117 /** @see DialerExecutorFactory#createUiTaskBuilder(FragmentManager, String, Worker) */
122 @NonNull Worker<InputT, OutputT> worker) {
[all...] |
| /external/icu/android_icu4j/src/main/tests/android/icu/dev/test/translit/ |
| ThreadTest.java | 23 private ArrayList<Worker> threads = new ArrayList<Worker>();
38 Worker thread = new Worker();
43 for (Worker thread: threads) {
61 private class Worker extends Thread {
|
| /external/icu/icu4j/main/tests/translit/src/com/ibm/icu/dev/test/translit/ |
| ThreadTest.java | 22 private ArrayList<Worker> threads = new ArrayList<Worker>();
37 Worker thread = new Worker();
42 for (Worker thread: threads) {
60 private class Worker extends Thread {
|
| /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>'; did you mean to use '->' instead of '.'?}} \
63 // expected-error {{no member named 'DoSamething' in 'arrow_suggest::Worker'; did you mean 'DoSomething'?}}
64 worker.Chuck(); // expected-error {{no member named 'Chuck' in 'arrow_suggest::wrapped_ptr<arrow_suggest: (…)
[all...] |
| /external/clang/test/Sema/ |
| attr-capabilities.c | 27 ThreadRole GUI, Worker;
29 void Func2(void) __attribute__((requires_shared_capability(Worker))) {}
61 void Func28(void) __attribute__((requires_capability(GUI && Worker)));
62 void Func29(void) __attribute__((requires_capability(GUI || Worker)));
63 void Func30(void) __attribute__((requires_capability((Worker || Worker) && !GUI)));
|
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Lib/test/ |
| threaded_import_hangers.py | 21 class Worker(threading.Thread):
38 t = Worker(func, args)
|
| /external/python/cpython2/Lib/test/ |
| threaded_import_hangers.py | 21 class Worker(threading.Thread):
38 t = Worker(func, args)
|
| /prebuilts/gdb/darwin-x86/lib/python2.7/test/ |
| threaded_import_hangers.py | 21 class Worker(threading.Thread):
38 t = Worker(func, args)
|
| /prebuilts/gdb/linux-x86/lib/python2.7/test/ |
| threaded_import_hangers.py | 21 class Worker(threading.Thread):
38 t = Worker(func, args)
|
| /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/snakeyaml/src/test/java/org/yaml/snakeyaml/stress/ |
| ParallelTest.java | 34 Worker worker = new Worker(i, doc); local
35 Thread thread = new Thread(worker);
47 private class Worker implements Runnable {
51 public Worker(int id, String doc) {
|
| /external/vulkan-validation-layers/demos/smoke/ |
| Smoke.h | 52 class Worker {
54 Worker(Smoke &smoke, int index, int object_begin, int object_end);
82 static void thread_loop(Worker *worker) { worker->update_loop(); }
122 std::vector<std::unique_ptr<Worker>> workers_;
184 void update_simulation(const Worker &worker);
186 void draw_objects(Worker &worker);
[all...] |
| /external/drm_hwcomposer/tests/ |
| worker_test.cpp | 6 #include "worker.h"
8 using android::Worker;
10 struct TestWorker : public Worker {
12 : Worker("test-worker", HAL_PRIORITY_URGENT_DISPLAY),
57 TestWorker worker; member in struct:WorkerTest
60 worker.Init();
70 ASSERT_TRUE(worker.initialized());
72 int val = worker.value;
76 ASSERT_EQ(val, worker.value)
[all...] |
| /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...] |
