From 3061bfbf1c4b5092fa4234de3105a615fcef18ea Mon Sep 17 00:00:00 2001 From: Douglas Rumbaugh Date: Fri, 31 Jan 2025 16:16:28 -0500 Subject: More updates --- include/framework/scheduling/FIFOScheduler.h | 2 ++ 1 file changed, 2 insertions(+) (limited to 'include/framework/scheduling/FIFOScheduler.h') diff --git a/include/framework/scheduling/FIFOScheduler.h b/include/framework/scheduling/FIFOScheduler.h index 7cb6d20..4c1db8d 100644 --- a/include/framework/scheduling/FIFOScheduler.h +++ b/include/framework/scheduling/FIFOScheduler.h @@ -82,6 +82,7 @@ private: std::atomic m_counter; std::mutex m_cv_lock; std::condition_variable m_cv; + std::mutex m_queue_lock; std::thread m_sched_thrd; std::thread m_sched_wakeup_thrd; @@ -102,6 +103,7 @@ private: } void schedule_next() { + auto lk = std::unique_lock(m_queue_lock); assert(m_task_queue.size() > 0); auto t = m_task_queue.pop(); m_stats.job_scheduled(t.m_timestamp); -- cgit v1.2.3