Checkpoint synchronization: Difference between revisions
m
→{{header|Oforth}}
Line 1,430:
func: checkPoint(n, jobs, channels)
{
while(true) [
#[ jobs receive drop ] times(n)
"CHECKPOINT : All jobs done, sending done to all tasks" println
channels
]
}
| |||