[p5sagit/p5-mst-13.2.git] / queue.t

use Thread;
use Thread::Queue;

$q = new Thread::Queue;

sub reader {
    my $i;
    for ($i = 1; $i <= 10; $i++) {
	print "reader: waiting for element $i...\n";
	my $el = $q->dequeue;
	print "reader: dequeued element $i: value $el\n";
    }
}

new Thread \&reader;
my $i;
for ($i = 1; $i <= 10; $i++) {
    my $el = int(rand(100));
    select(undef, undef, undef, rand(2));
    print "writer: enqueuing value $el\n";
    $q->enqueue($el);
}
Commit	Line	Data
19be36ba	1	use Thread;
	2	use Thread::Queue;
	3
	4	$q = new Thread::Queue;
	5
	6	sub reader {
	7	my $i;
	8	for ($i = 1; $i <= 10; $i++) {
	9	print "reader: waiting for element $i...\n";
	10	my $el = $q->dequeue;
	11	print "reader: dequeued element $i: value $el\n";
	12	}
	13	}
	14
	15	new Thread \&reader;
	16	my $i;
	17	for ($i = 1; $i <= 10; $i++) {
	18	my $el = int(rand(100));
	19	select(undef, undef, undef, rand(2));
	20	print "writer: enqueuing value $el\n";
	21	$q->enqueue($el);
	22	}