| 124 | } |
| 125 | |
| 126 | void JobQue::push(Job && job, JobCategory category, JobPriority priority) { |
| 127 | lock_guard<mutex> lock(mFifoMutex); |
| 128 | submit(das::move(job), category, priority); |
| 129 | mCond.notify_one(); |
| 130 | } |
| 131 | |
| 132 | void JobQue::job(int threadIndex) { |
| 133 | while (!mShutdown) { |
no outgoing calls