Checkpoint synchronization: Difference between revisions

m
Line 1,405:
Checkpoint is implemented as a task. It :
 
- Receives n "allDonejobDone" events from n tasks into a "jobs" channel.
 
- Then sends $doneallDone event to all tasks so they can work again.
 
Each task :
Line 1,415:
- Then sends "jobDone" to the checkpoint using "jobs" channel.
 
- And waits for $allDone checkpoint return on its personal channel.
 
<lang Oforth>func: task(n, jobs, myChannel)
1,015

edits