Populate all available worker slots on each main loop run
This commit is contained in:
parent
0fd1fae6dc
commit
96d23d9a7d
@ -162,3 +162,5 @@ Sanity checks raised $sanitywarn warnings... Hit Control-C to abort." >&2
|
|||||||
fi
|
fi
|
||||||
fi
|
fi
|
||||||
}
|
}
|
||||||
|
|
||||||
|
# vim:set ts=8 sw=8:
|
||||||
|
|||||||
@ -17,6 +17,8 @@ master() {
|
|||||||
return 0
|
return 0
|
||||||
fi
|
fi
|
||||||
|
|
||||||
|
until (( active == concurrency || remaining == 0 ))
|
||||||
|
do
|
||||||
echo '
|
echo '
|
||||||
SELECT COUNT(*)
|
SELECT COUNT(*)
|
||||||
FROM tasks
|
FROM tasks
|
||||||
@ -110,7 +112,7 @@ master() {
|
|||||||
if (( ready > 0 ))
|
if (( ready > 0 ))
|
||||||
then
|
then
|
||||||
createworker
|
createworker
|
||||||
return 0
|
continue
|
||||||
fi
|
fi
|
||||||
|
|
||||||
echo '
|
echo '
|
||||||
@ -225,5 +227,13 @@ master() {
|
|||||||
else
|
else
|
||||||
createworker
|
createworker
|
||||||
fi
|
fi
|
||||||
|
echo '
|
||||||
|
SELECT COUNT(*)
|
||||||
|
FROM tasks
|
||||||
|
WHERE status = 0;
|
||||||
|
'>&3
|
||||||
|
|
||||||
|
read -u4 remaining
|
||||||
|
done
|
||||||
fi
|
fi
|
||||||
}
|
}
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user