| /hardware/interfaces/biometrics/common/thread/include/thread/ |
| D | WorkerThread.h | 30 class WorkerThread final {
34 explicit WorkerThread(size_t maxQueueSize);
38 ~WorkerThread();
41 WorkerThread(const WorkerThread&) = delete;
42 WorkerThread& operator=(const WorkerThread&) = delete;
45 WorkerThread(WorkerThread&&) = delete;
46 WorkerThread& operator=(WorkerThread&&) = delete;
|
| /hardware/interfaces/broadcastradio/common/utils/ |
| D | WorkerThread.cpp | 29 bool operator<(const WorkerThread::Task& lhs, const WorkerThread::Task& rhs) { in operator <()
33 WorkerThread::WorkerThread() : mIsTerminating(false) { in WorkerThread() function in android::WorkerThread
36 mThread = std::thread(&WorkerThread::threadLoop, this); in WorkerThread()
39 WorkerThread::~WorkerThread() { in ~WorkerThread()
48 void WorkerThread::schedule(function<void()> task, milliseconds delay) { in schedule()
53 void WorkerThread::schedule(function<void()> task, function<void()> cancelTask, in schedule()
62 void WorkerThread::cancelAll() { in cancelAll()
71 void WorkerThread::threadLoop() { in threadLoop()
|
| D | Android.bp | 36 "WorkerThread.cpp",
|
| /hardware/interfaces/biometrics/common/thread/ |
| D | WorkerThread.cpp | 23 WorkerThread::WorkerThread(size_t maxQueueSize) in WorkerThread() function in aidl::android::hardware::biometrics::WorkerThread
29 mThread(&WorkerThread::threadFunc, this) {} in WorkerThread()
31 WorkerThread::~WorkerThread() { in ~WorkerThread()
42 bool WorkerThread::schedule(std::unique_ptr<Callable> task) { in schedule()
57 void WorkerThread::threadFunc() { in threadFunc()
|
| D | Android.bp | 15 "WorkerThread.cpp",
24 "WorkerThread.cpp",
|
| /hardware/google/aemu/base/ |
| D | WorkerThread_unittest.cpp | 24 TEST(WorkerThread, TheReturnedFutureFromEnqueueShouldBeReadyWhenTheWorkerStops) { in TEST() argument
26 WorkerThread<Item> worker([](Item&&) { return WorkerProcessingResult::Stop; }); in TEST()
33 TEST(WorkerThread, TheReturnedFutureFromEnqueueShouldBeReadyBeforeTheWorkerStarts) { in TEST() argument
35 WorkerThread<Item> worker([](Item&&) { return WorkerProcessingResult::Stop; }); in TEST()
|
| /hardware/interfaces/broadcastradio/common/tests/ |
| D | WorkerThread_test.cpp | 24 using android::WorkerThread;
42 WorkerThread thread; in TEST()
62 WorkerThread thread; in TEST()
78 WorkerThread thread; in TEST()
125 WorkerThread thread; in TEST()
|
| /hardware/interfaces/broadcastradio/common/utils/include/broadcastradio-utils/ |
| D | WorkerThread.h | 27 class WorkerThread {
29 WorkerThread();
30 virtual ~WorkerThread();
|
| /hardware/interfaces/broadcastradio/aidl/default/ |
| D | BroadcastRadio.h | 75 std::unique_ptr<::android::WorkerThread> mTuningThread GUARDED_BY(mMutex) =
76 std::unique_ptr<::android::WorkerThread>(new ::android::WorkerThread());
77 std::unique_ptr<::android::WorkerThread> mProgramListThread GUARDED_BY(mMutex) =
78 std::unique_ptr<::android::WorkerThread>(new ::android::WorkerThread());
|
| /hardware/interfaces/biometrics/common/thread/tests/ |
| D | WorkerThreadTest.cpp | 32 WorkerThread worker(1 /*maxQueueSize*/); in TEST()
47 WorkerThread worker(2 /*maxQueueSize*/); in TEST()
73 WorkerThread worker(NUM_TASKS + 1); in TEST()
111 WorkerThread worker(2 /*maxQueueSize*/); in TEST()
|
| /hardware/google/aemu/base/include/aemu/base/threads/ |
| D | WorkerThread.h | 67 class WorkerThread {
68 DISALLOW_COPY_AND_ASSIGN(WorkerThread);
75 WorkerThread(Processor&& processor) in WorkerThread() function
79 ~WorkerThread() { join(); } in ~WorkerThread()
|
| D | ThreadPool.h | 83 using Worker = WorkerThread<Optional<Command>>;
|
| /hardware/google/gfxstream/host/compressedTextureFormats/ |
| D | AstcCpuDecompressorImpl.cpp | 158 class WorkerThread { class
160 explicit WorkerThread() : mThread(&WorkerThread::main, this) {} in WorkerThread() function in gfxstream::vk::__anon87c057260111::WorkerThread
271 std::array<WorkerThread, kNumThreads> mWorkerThreads;
|
| /hardware/interfaces/biometrics/fingerprint/aidl/default/include/ |
| D | Session.h | 50 FakeFingerprintEngine* engine, WorkerThread* worker);
140 WorkerThread* mWorker;
|
| D | Fingerprint.h | 62 WorkerThread mWorker;
|
| /hardware/interfaces/broadcastradio/2.0/default/ |
| D | TunerSession.h | 57 WorkerThread mThread;
|
| /hardware/interfaces/broadcastradio/1.1/default/ |
| D | Tuner.h | 58 WorkerThread mThread;
|
| /hardware/interfaces/biometrics/fingerprint/aidl/default/tests/ |
| D | SessionTest.cpp | 105 WorkerThread mWorker;
|
| /hardware/interfaces/biometrics/face/aidl/default/ |
| D | Session.h | 118 std::unique_ptr<WorkerThread> mThread;
|
| D | Session.cpp | 43 mThread = std::make_unique<WorkerThread>(MAX_WORKER_QUEUE_SIZE); in Session()
|
| /hardware/google/gfxstream/host/ |
| D | FrameBuffer.h | 811 android::base::WorkerThread<Readback> m_readbackThread;
840 android::base::WorkerThread<Post> m_postThread;
|
| D | RendererImpl.cpp | 110 android::base::WorkerThread<Cmd> mCleanupWorker;
|
| D | virtio-gpu-gfxstream-renderer.cpp | 676 android::base::WorkerThread<CleanupTask> mWorker;
|
| /hardware/interfaces/biometrics/fingerprint/aidl/default/ |
| D | Session.cpp | 37 FakeFingerprintEngine* engine, WorkerThread* worker) in Session()
|