| /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) {
|
| /frameworks/support/work/workmanager-ktx/src/androidTest/java/androidx/work/workers/ |
| TestWorker.kt | 19 import androidx.work.Worker
21 class TestWorker : Worker() {
|
| /frameworks/support/work/workmanager/src/androidTest/java/androidx/work/worker/ |
| EchoingWorker.java | 17 package androidx.work.worker;
21 import androidx.work.Worker;
23 public class EchoingWorker extends Worker {
|
| ExceptionWorker.java | 17 package androidx.work.worker;
21 import androidx.work.Worker;
23 public class ExceptionWorker extends Worker {
|
| InfiniteTestWorker.java | 17 package androidx.work.worker;
21 import androidx.work.Worker;
24 * Test Worker that loops until Thread is interrupted.
27 public class InfiniteTestWorker extends Worker {
|
| FailureWorker.java | 17 package androidx.work.worker;
22 import androidx.work.Worker;
25 * Worker that fails.
28 public class FailureWorker extends Worker {
|
| InterruptionAwareWorker.java | 17 package androidx.work.worker;
21 import androidx.work.Worker;
23 public class InterruptionAwareWorker extends Worker {
|
| LongRunningWorker.java | 17 package androidx.work.worker;
21 import androidx.work.Worker;
23 public class LongRunningWorker extends Worker {
|
| RetryWorker.java | 17 package androidx.work.worker;
22 import androidx.work.Worker;
25 * Worker that fails.
28 public class RetryWorker extends Worker {
|
| SleepTestWorker.java | 17 package androidx.work.worker;
22 import androidx.work.Worker;
25 * Worker that sleeps for 5 seconds before returning.
28 public class SleepTestWorker extends Worker {
|
| TestWorker.java | 17 package androidx.work.worker;
22 import androidx.work.Worker;
25 * Simple Test Worker
28 public class TestWorker extends Worker {
|
| /frameworks/support/work/workmanager-firebase/src/androidTest/java/androidx/work/worker/ |
| FirebaseInfiniteTestWorker.java | 17 package androidx.work.worker;
21 import androidx.work.Worker;
24 * Test Worker that loops until Thread is interrupted.
27 public class FirebaseInfiniteTestWorker extends Worker {
|
| FirebaseTestWorker.java | 17 package androidx.work.worker;
22 import androidx.work.Worker;
25 * Simple Test Worker
28 public class FirebaseTestWorker extends Worker {
|
| /external/libxcam/xcore/ |
| worker.cpp | 2 * worker.cpp - worker implementation
21 #include "worker.h"
25 Worker::Worker (const char *name, const SmartPtr<Callback> &cb)
33 Worker::~Worker ()
39 Worker::set_name (const char *name)
43 false, "worker set name failed with parameter NULL");
47 "worker(%s) set name(%s) failed, already got a name", XCAM_STR (get_name ()), XCAM_STR (name))
132 SmartPtr<Worker> worker = new UnitTestWorker; local
[all...] |
| worker.h | 2 * worker.h - worker class interface
29 class CbClass : public ::XCam::Worker::Callback { \
33 const ::XCam::SmartPtr<::XCam::Worker> &worker, \
34 const ::XCam::SmartPtr<::XCam::Worker::Arguments> &args, \
36 _h->mem_func (worker, args, error); } \
41 class Worker
59 const SmartPtr<Worker> &worker, const SmartPtr<Arguments> &args, const XCamReturn error) = 0
[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();
|
| /external/libxcam/modules/soft/ |
| soft_blender.h | 70 const SmartPtr<Worker> &worker, const SmartPtr<Worker::Arguments> &args, const XCamReturn error);
72 const SmartPtr<Worker> &worker, const SmartPtr<Worker::Arguments> &args, const XCamReturn error);
74 const SmartPtr<Worker> &worker, const SmartPtr<Worker::Arguments> &args, const XCamReturn error);
76 const SmartPtr<Worker> &worker, const SmartPtr<Worker::Arguments> &args, const XCamReturn error)
[all...] |
| /frameworks/support/work/integration-tests/testapp/src/main/java/androidx/work/integration/testapp/ |
| InfiniteWorker.java | 21 import androidx.work.Worker;
23 public class InfiniteWorker extends Worker {
|
| TestWorker.java | 20 import androidx.work.Worker;
23 * A Test Worker.
25 public class TestWorker extends Worker {
|
| /frameworks/support/work/workmanager/src/main/java/androidx/work/impl/workers/ |
| CombineContinuationsWorker.java | 22 import androidx.work.Worker;
25 * A {@link Worker} that helps combine work continuations.
30 public class CombineContinuationsWorker extends Worker {
|
| /frameworks/support/work/workmanager-test/src/androidTest/java/androidx/work/test/workers/ |
| TestWorker.java | 22 import androidx.work.Worker;
24 public class TestWorker extends 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...] |
| /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);
|
