Coro/t/15_semaphore.t

$|=1;
print "1..1\n";

use Coro;
use Coro::Semaphore;

my $sem = new Coro::Semaphore 2;

my $rand = 0;

sub xrand {
   $rand = ($rand * 121 + 2121) % 212121;
   $rand / 212120
}

my $counter;

$_->join for
   map {
      async {
         my $current = $Coro::current;
         for (1..100) {
            cede if 0.2 > xrand;
            Coro::async_pool { $current->ready } if 0.2 > xrand;
            $counter += $sem->count;
            my $guard = $sem->guard;
            cede; cede; cede; cede;
         }
      }
   } 1..15
;

print $counter == 750 ? "" : "not ", "ok 1 # $counter\n"

Revision:	1.1
Committed:	Sat Nov 15 06:26:52 2008 UTC (15 years, 7 months ago) by root
Content type:	application/x-troff
Branch:	MAIN
Log Message:	* empty log message *
#	User	Rev	Content
1	root	1.1	$\|=1;
2			print "1..1\n";
3
4			use Coro;
5			use Coro::Semaphore;
6
7			my $sem = new Coro::Semaphore 2;
8
9			my $rand = 0;
10
11			sub xrand {
12			$rand = ($rand * 121 + 2121) % 212121;
13			$rand / 212120
14			}
15
16			my $counter;
17
18			$_->join for
19			map {
20			async {
21			my $current = $Coro::current;
22			for (1..100) {
23			cede if 0.2 > xrand;
24			Coro::async_pool { $current->ready } if 0.2 > xrand;
25			$counter += $sem->count;
26			my $guard = $sem->guard;
27			cede; cede; cede; cede;
28			}
29			}
30			} 1..15
31			;
32
33			print $counter == 750 ? "" : "not ", "ok 1 # $counter\n"
34