ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/cvsroot/Coro/Coro.pm
(Generate patch)

Comparing cvsroot/Coro/Coro.pm (file contents):
Revision 1.135 by root, Sat Sep 22 22:39:15 2007 UTC vs.
Revision 1.138 by root, Wed Sep 26 19:27:04 2007 UTC

50 50
51our $idle; # idle handler 51our $idle; # idle handler
52our $main; # main coroutine 52our $main; # main coroutine
53our $current; # current coroutine 53our $current; # current coroutine
54 54
55our $VERSION = '3.7'; 55our $VERSION = '3.8';
56 56
57our @EXPORT = qw(async async_pool cede schedule terminate current unblock_sub); 57our @EXPORT = qw(async async_pool cede schedule terminate current unblock_sub);
58our %EXPORT_TAGS = ( 58our %EXPORT_TAGS = (
59 prio => [qw(PRIO_MAX PRIO_HIGH PRIO_NORMAL PRIO_LOW PRIO_IDLE PRIO_MIN)], 59 prio => [qw(PRIO_MAX PRIO_HIGH PRIO_NORMAL PRIO_LOW PRIO_IDLE PRIO_MIN)],
60); 60);
155 # call all destruction callbacks 155 # call all destruction callbacks
156 $_->(@{$self->{status}}) 156 $_->(@{$self->{status}})
157 for @{(delete $self->{destroy_cb}) || []}; 157 for @{(delete $self->{destroy_cb}) || []};
158} 158}
159 159
160sub _do_trace {
161 $current->{_trace_cb}->();
162}
163
160# this coroutine is necessary because a coroutine 164# this coroutine is necessary because a coroutine
161# cannot destroy itself. 165# cannot destroy itself.
162my @destroy; 166my @destroy;
163my $manager; 167my $manager;
164 168
241 my $cb; 245 my $cb;
242 246
243 while () { 247 while () {
244 eval { 248 eval {
245 while () { 249 while () {
246# &{&_pool_1 or &terminate}; # crashes, would be ~5% faster
247 $cb = &_pool_1 250 _pool_1 $cb;
248 or &terminate;
249 &$cb; 251 &$cb;
250 undef $cb; 252 _pool_2 $cb;
251 &terminate if &_pool_2;
252 &schedule; 253 &schedule;
253 } 254 }
254 }; 255 };
255 256
257 last if $@ eq "\3terminate\2\n";
256 warn $@ if $@; 258 warn $@ if $@;
257 } 259 }
258} 260}
259 261
260sub async_pool(&@) { 262sub async_pool(&@) {

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines