--- Coro/Coro.pm 2001/07/25 21:12:57 1.25 +++ Coro/Coro.pm 2001/08/11 19:59:19 1.30 @@ -38,13 +38,14 @@ use base Exporter; -$VERSION = 0.12; +$VERSION = 0.45; @EXPORT = qw(async cede schedule terminate current); @EXPORT_OK = qw($current); { my @async; + my $init; # this way of handling attributes simply is NOT scalable ;() sub import { @@ -56,6 +57,13 @@ for (@_) { if ($_ eq "Coro") { push @async, $ref; + unless ($init++) { + eval q{ + sub INIT { + &async(pop @async) while @async; + } + }; + } } else { push @attrs, $_; } @@ -64,9 +72,6 @@ }; } - sub INIT { - &async(pop @async) while @async; - } } =item $main @@ -115,9 +120,6 @@ } }; -# we really need priorities... -my @ready; # the ready queue. hehe, rather broken ;) - # static methods. not really. =head2 STATIC METHODS @@ -157,14 +159,6 @@ =cut -my $prev; - -sub schedule { - # should be done using priorities :( - ($prev, $current) = ($current, shift @ready || $idle); - Coro::State::transfer($prev, $current); -} - =item cede "Cede" to other processes. This function puts the current process into the @@ -173,11 +167,6 @@ =cut -sub cede { - $current->ready; - &schedule; -} - =item terminate Terminates the current process. @@ -187,10 +176,9 @@ =cut sub terminate { - push @destroy, $current; - $manager->ready; + $current->cancel; &schedule; - # NORETURN + die; # NORETURN } =back @@ -231,8 +219,15 @@ =cut -sub ready { - push @ready, $_[0]; +=item $process->cancel + +Like C, but terminates the specified process instead. + +=cut + +sub cancel { + push @destroy, $_[0]; + $manager->ready; } =back @@ -259,7 +254,7 @@ L, L, L, L, L, L, L, L, -L, L. +L, L. =head1 AUTHOR