diff options
| author | Kartik K. Agaram <vc@akkartik.com> | 2015-01-10 13:49:16 -0800 |
|---|---|---|
| committer | Kartik K. Agaram <vc@akkartik.com> | 2015-01-10 13:49:16 -0800 |
| commit | ea0d661bb77ca3a844ff7c7268cd5a9b3266265c (patch) | |
| tree | d68c3c67405e3125f5284cc5a4d958ced7a358bd /channel.mu | |
| parent | 9c2ed239561c069beba0953616ddab15ac21265b (diff) | |
| download | mu-ea0d661bb77ca3a844ff7c7268cd5a9b3266265c.tar.gz | |
529 - 'sleep' can now wait for a routine to complete
Diffstat (limited to 'channel.mu')
| -rw-r--r-- | channel.mu | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/channel.mu b/channel.mu index 8e03cdc2..4fa6adaf 100644 --- a/channel.mu +++ b/channel.mu @@ -41,7 +41,8 @@ (function main [ (chan:channel-address <- init-channel 3:literal) ; create two background 'routines' that communicate by a channel - (fork consumer:fn nil:literal/globals nil:literal/limit chan:channel-address) - (fork producer:fn nil:literal/globals nil:literal/limit chan:channel-address) - (sleep for-some-cycles:literal 2000:literal) ; wait for forked routines to effect the transfer + (routine1:integer <- fork consumer:fn nil:literal/globals nil:literal/limit chan:channel-address) + (routine2:integer <- fork producer:fn nil:literal/globals nil:literal/limit chan:channel-address) + (sleep until-routine-done:literal routine1:integer) + (sleep until-routine-done:literal routine2:integer) ]) |