Checkpoint synchronization: Difference between revisions

m
Line 1,422:
System.Out "TASK " << n << " : Beginning my work..." << cr
System sleep(n 100 * rand)
jobs send(n$jobDone) drop
System.Out "TASK " << n << " : Finish, waiting for others..." << cr
myChannel receive drop
Line 1,433:
#[ jobs receive drop ] times(n)
"CHECKPOINT : All jobs done, sending done to all tasks" println
channels apply(#[ send($doneallDone) drop ])
]
}
1,015

edits