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

Comparing Coro/Coro.pm (file contents):
Revision 1.133 by root, Fri Sep 21 01:23:58 2007 UTC vs.
Revision 1.134 by root, Sat Sep 22 14:42:56 2007 UTC

… …
227 227
228If you are concerned about pooled coroutines growing a lot because a 228If you are concerned about pooled coroutines growing a lot because a
229single C<async_pool> used a lot of stackspace you can e.g. C<async_pool 229single C<async_pool> used a lot of stackspace you can e.g. C<async_pool
230{ terminate }> once per second or so to slowly replenish the pool. In 230{ terminate }> once per second or so to slowly replenish the pool. In
231addition to that, when the stacks used by a handler grows larger than 16kb 231addition to that, when the stacks used by a handler grows larger than 16kb
232(adjustable with $Coro::MAX_POOL_RSS) it will also exit. 232(adjustable with $Coro::POOL_RSS) it will also exit.
233 233
234=cut 234=cut
235 235
236our $POOL_SIZE = 8; 236our $POOL_SIZE = 8;
237our $MAX_POOL_RSS = 16 * 1024; 237our $POOL_RSS = 16 * 1024;
238our @pool; 238our @async_pool;
239 239
240sub pool_handler { 240sub pool_handler {
241 my $cb;
242
241 while () { 243 while () {
242 $current->{desc} = "[async_pool]";
243
244 eval { 244 eval {
245 my ($cb, @arg) = @{ delete $current->{_invoke} or return }; 245 while () {
246 $cb->(@arg); 246 $cb = &_pool_1
247 or return;
248
249 &$cb;
250
251 return if &_pool_2;
252
253 undef $cb;
254 schedule;
255 }
247 }; 256 };
257
248 warn $@ if $@; 258 warn $@ if $@;
249
250 last if @pool >= $POOL_SIZE || $current->rss >= $MAX_POOL_RSS;
251
252 push @pool, $current;
253 $current->{desc} = "[async_pool idle]";
254 $current->save (Coro::State::SAVE_DEF);
255 $current->prio (0);
256 schedule;
257 } 259 }
258} 260}
259 261
260sub async_pool(&@) { 262sub async_pool(&@) {
261 # this is also inlined into the unlock_scheduler 263 # this is also inlined into the unlock_scheduler
262 my $coro = (pop @pool) || new Coro \&pool_handler;; 264 my $coro = (pop @async_pool) || new Coro \&pool_handler;;
263 265
264 $coro->{_invoke} = [@_]; 266 $coro->{_invoke} = [@_];
265 $coro->ready; 267 $coro->ready;
266 268
267 $coro 269 $coro
… …
537# inside an event callback. 539# inside an event callback.
538our $unblock_scheduler = new Coro sub { 540our $unblock_scheduler = new Coro sub {
539 while () { 541 while () {
540 while (my $cb = pop @unblock_queue) { 542 while (my $cb = pop @unblock_queue) {
541 # this is an inlined copy of async_pool 543 # this is an inlined copy of async_pool
542 my $coro = (pop @pool or new Coro \&pool_handler); 544 my $coro = (pop @async_pool) || new Coro \&pool_handler;
543 545
544 $coro->{_invoke} = $cb; 546 $coro->{_invoke} = $cb;
545 $coro->ready; 547 $coro->ready;
546 cede; # for short-lived callbacks, this reduces pressure on the coro pool 548 cede; # for short-lived callbacks, this reduces pressure on the coro pool
547 } 549 }

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines