Searched refs:WorkQueue (Results 1 – 14 of 14) sorted by relevance
27 WorkQueue::WorkQueue(size_t maxThreads, bool canCallJava) : in WorkQueue() function in android::WorkQueue32 WorkQueue::~WorkQueue() { in ~WorkQueue()38 status_t WorkQueue::schedule(WorkUnit* workUnit, size_t backlog) { in schedule()68 status_t WorkQueue::cancel() { in cancel()74 status_t WorkQueue::cancelLocked() { in cancelLocked()93 status_t WorkQueue::finish() { in finish()115 bool WorkQueue::threadLoop() { in threadLoop()160 WorkQueue::WorkThread::WorkThread(WorkQueue* workQueue, bool canCallJava) : in WorkThread()164 WorkQueue::WorkThread::~WorkThread() { in ~WorkThread()167 bool WorkQueue::WorkThread::threadLoop() { in threadLoop()
34 class WorkQueue {50 explicit WorkQueue(size_t maxThreads, bool canCallJava = true);55 ~WorkQueue();91 WorkThread(WorkQueue* workQueue, bool canCallJava);97 WorkQueue* const mWorkQueue;
105 "WorkQueue.cpp",
345 class PreProcessImageWorkUnit : public WorkQueue::WorkUnit {373 WorkQueue wq(MAX_THREADS, false); in preProcessImages()
35 WorkQueue& queue() { return mQueue; } in queue()51 int timeout = nextWakeup - WorkQueue::clock::now(); in waitForWork()69 WorkQueue mQueue;
39 WorkQueue& queue() { return mQueue; } in queue()61 timeout = ns2ms(nextWakeup - WorkQueue::clock::now()); in waitForWork()83 WorkQueue mQueue;
37 class WorkQueue {38 PREVENT_COPY_AND_ASSIGN(WorkQueue);59 WorkQueue(std::function<void()>&& wakeFunc, std::mutex& lock) in WorkQueue() function
634 std::unique_ptr<C2Work> SimpleC2Component::WorkQueue::pop_front() { in pop_front()640 void SimpleC2Component::WorkQueue::push_back(std::unique_ptr<C2Work> work) { in push_back()644 bool SimpleC2Component::WorkQueue::empty() const { in empty()648 void SimpleC2Component::WorkQueue::clear() { in clear()652 uint32_t SimpleC2Component::WorkQueue::drainMode() const { in drainMode()656 void SimpleC2Component::WorkQueue::markDrain(uint32_t drainMode) { in markDrain()843 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in queue_nb()871 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in flush_sm()901 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in drain_nb()945 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in stop()[all …]
39 static WorkQueue& queue() { in queue()53 using clock = WorkQueue::clock; in TEST()
267 class WorkQueue {271 inline WorkQueue() : mFlush(false), mGeneration(0ul) {} in WorkQueue() function300 Mutexed<WorkQueue> mWorkQueue;
136 WorkQueue& queue() { return ThreadBase::queue(); } in queue()
780 Ljava/util/concurrent/ForkJoinPool$WorkQueue; 169
15839 java.util.concurrent.ForkJoinPool$WorkQueue17715 [Ljava.util.concurrent.ForkJoinPool$WorkQueue;
48424 Ljava/util/concurrent/ForkJoinPool$WorkQueue;50307 [Ljava/util/concurrent/ForkJoinPool$WorkQueue;