| 290 | Cv.notify_one(); |
| 291 | } |
| 292 | FuzzJob *Pop() { |
| 293 | std::unique_lock<std::mutex> Lk(Mu); |
| 294 | // std::lock_guard<std::mutex> Lock(Mu); |
| 295 | Cv.wait(Lk, [&]{return !Qu.empty();}); |
| 296 | assert(!Qu.empty()); |
| 297 | auto Job = Qu.front(); |
| 298 | Qu.pop(); |
| 299 | return Job; |
| 300 | } |
| 301 | }; |
| 302 | |
| 303 | void WorkerThread(JobQueue *FuzzQ, JobQueue *MergeQ) { |
no test coverage detected