[ViewVC] Annotation of: cvs/Coro/eg/prodcons3

#!/usr/bin/perl

# the classical producer/consumer example, using semaphores
# one process produces items, send s a signal.
# another process waits for that signal and
# consumed the item.

use Coro;
use Coro::Channel;
use Coro::Signal;

my $work = new Coro::Channel 3;
my $finished = new Coro::Signal;

async {
   for my $i (0..9) {
      print "produced $i\n";
      $work->put($i);
   }
   print "work done\n";
   $finished->send;
};

async {
   while () {
      my $i = $work->get;
      print "consumed $i\n";
   }
};

$finished->wait;

print "producer finished\n";

yield while $work->size;

print "job finished\n";

Revision:	1.2
Committed:	Sun Jul 15 02:35:52 2001 UTC (22 years, 11 months ago) by root
Branch:	MAIN
Changes since 1.1:	+0 -1 lines
Log Message:	* empty log message *
#	User	Rev	Content
1	root	1.1	#!/usr/bin/perl
2
3			# the classical producer/consumer example, using semaphores
4			# one process produces items, send s a signal.
5			# another process waits for that signal and
6			# consumed the item.
7
8			use Coro;
9			use Coro::Channel;
10			use Coro::Signal;
11
12			my $work = new Coro::Channel 3;
13			my $finished = new Coro::Signal;
14
15			async {
16			for my $i (0..9) {
17			print "produced $i\n";
18			$work->put($i);
19			}
20			print "work done\n";
21			$finished->send;
22			};
23
24			async {
25			while () {
26			my $i = $work->get;
27			print "consumed $i\n";
28			}
29			};
30
31			$finished->wait;
32
33			print "producer finished\n";
34
35			yield while $work->size;
36
37			print "job finished\n";
38