Checkpoint synchronization: Difference between revisions
m
→{{header|Oforth}}
Line 1,430:
func: checkPoint(n, jobs, channels)
{
| i ch |
while(true) [
"CHECKPOINT : All jobs done, sending done to all tasks" println
channels
]
}
Line 1,441 ⟶ 1,442:
| jobs channels i |
n seq map(#[ drop Channel new]) ->channels
Channel
#[ checkPoint(n, jobs, channels) ] &
n loop: i [ #[ task(i, jobs, channels at(i)) ] & ]
}
=={{header|Perl}}==
| |||