This commit is contained in:
serxa 2024-08-30 19:33:34 +00:00
parent 3675e83a3f
commit 9f96d18060

View File

@ -103,12 +103,10 @@ public:
// That thread will continue execution and do real consumption of requested resource synchronously.
void execute() override
{
{
std::unique_lock lock(mutex);
chassert(state == Enqueued);
state = Dequeued;
dequeued_cv.notify_one();
}
std::unique_lock lock(mutex);
chassert(state == Enqueued);
state = Dequeued;
dequeued_cv.notify_one();
}
void wait()