max/lean4-htt
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 2

fix(library/mt_task_queue): work around non-recursive lock

Browse source
This commit is contained in:
Gabriel Ebner 2017-06-06 19:57:04 +02:00
parent 559211d284
commit 34d5c0f769
1 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
src/library/mt_task_queue.cpp
View file

@ -151,7 +151,8 @@ void mt_task_queue::handle_finished(gtask const & t) {
m_waiting.erase(rdep);
if (get_state(rdep).load() < task_state::Running) {
lean_always_assert(get_data(rdep));
if (get_data(rdep)->m_flags.m_eager_execution) {
// TODO(gabriel): we need to give up the lock on m_mutex for this
if (false && get_data(rdep)->m_flags.m_eager_execution) {
get_state(rdep) = task_state::Running;
execute(rdep);
handle_finished(rdep);
@ -188,7 +189,8 @@ void mt_task_queue::submit_core(gtask const & t, unsigned prio) {
get_data(t)->m_sched_info.reset(new mt_sched_info(prio));
if (check_deps(t)) {
if (get_state(t).load() < task_state::Running) {
if (get_data(t)->m_flags.m_eager_execution) {
// TODO(gabriel): we need to give up the lock on m_mutex for this
if (false && get_data(t)->m_flags.m_eager_execution) {
get_state(t) = task_state::Running;
execute(t);
handle_finished(t);