| 236 | ~FailCancelWorker() {} |
| 237 | |
| 238 | void WaitForWorkerTaskToStart() { |
| 239 | std::unique_lock<std::mutex> lk(mu); |
| 240 | taskStartingCv.wait(lk, [this] { return taskIsRunning; }); |
| 241 | taskIsRunning = false; |
| 242 | } |
| 243 | |
| 244 | static void DoCancel(const CallbackInfo& info) { |
| 245 | Function cb = info[0].As<Function>(); |