Checkpoint synchronization: Difference between revisions
Content deleted Content added
Line 1,430: | Line 1,430: | ||
func: checkPoint(n, jobs, channels) |
func: checkPoint(n, jobs, channels) |
||
{ |
{ |
||
| i ch | |
|||
while(true) [ |
while(true) [ |
||
#[ jobs receive drop ] times(n) |
|||
"CHECKPOINT : All jobs done, sending done to all tasks" println |
"CHECKPOINT : All jobs done, sending done to all tasks" println |
||
channels |
channels apply(#[ send($done) drop ]) |
||
] |
] |
||
} |
} |
||
Line 1,446: | Line 1,445: | ||
#[ checkPoint(n, jobs, channels) ] & |
#[ checkPoint(n, jobs, channels) ] & |
||
n loop: i [ #[ task(i, jobs, channels at(i)) ] & ] |
n loop: i [ #[ task(i, jobs, channels at(i)) ] & ] |
||
⚫ | |||
} |
|||
⚫ | |||
=={{header|Perl}}== |
=={{header|Perl}}== |