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

Comparing Coro/Coro.pm (file contents):
Revision 1.132 by root, Thu Sep 20 22:53:23 2007 UTC vs.
Revision 1.135 by root, Sat Sep 22 22:39:15 2007 UTC

… …
224The pool size is limited to 8 idle coroutines (this can be adjusted by 224The pool size is limited to 8 idle coroutines (this can be adjusted by
225changing $Coro::POOL_SIZE), and there can be as many non-idle coros as 225changing $Coro::POOL_SIZE), and there can be as many non-idle coros as
226required. 226required.
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
230terminate }> once per second or so to slowly replenish the pool. 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
232(adjustable with $Coro::POOL_RSS) it will also exit.
231 233
232=cut 234=cut
233 235
234our $POOL_SIZE = 8; 236our $POOL_SIZE = 8;
235our $MAX_POOL_RSS = 64 * 1024; 237our $POOL_RSS = 16 * 1024;
236our @pool; 238our @async_pool;
237 239
238sub pool_handler { 240sub pool_handler {
241 my $cb;
242
239 while () { 243 while () {
240 $current->{desc} = "[async_pool]";
241
242 eval { 244 eval {
243 my ($cb, @arg) = @{ delete $current->{_invoke} or return }; 245 while () {
244 $cb->(@arg); 246# &{&_pool_1 or &terminate}; # crashes, would be ~5% faster
247 $cb = &_pool_1
248 or &terminate;
249 &$cb;
250 undef $cb;
251 &terminate if &_pool_2;
252 &schedule;
253 }
245 }; 254 };
255
246 warn $@ if $@; 256 warn $@ if $@;
247
248 last if @pool >= $POOL_SIZE || $current->rss >= $MAX_POOL_RSS;
249
250 push @pool, $current;
251 $current->{desc} = "[async_pool idle]";
252 $current->save (Coro::State::SAVE_DEF);
253 $current->prio (0);
254 schedule;
255 } 257 }
256} 258}
257 259
258sub async_pool(&@) { 260sub async_pool(&@) {
259 # this is also inlined into the unlock_scheduler 261 # this is also inlined into the unlock_scheduler
260 my $coro = (pop @pool) || new Coro \&pool_handler;; 262 my $coro = (pop @async_pool) || new Coro \&pool_handler;
261 263
262 $coro->{_invoke} = [@_]; 264 $coro->{_invoke} = [@_];
263 $coro->ready; 265 $coro->ready;
264 266
265 $coro 267 $coro
… …
535# inside an event callback. 537# inside an event callback.
536our $unblock_scheduler = new Coro sub { 538our $unblock_scheduler = new Coro sub {
537 while () { 539 while () {
538 while (my $cb = pop @unblock_queue) { 540 while (my $cb = pop @unblock_queue) {
539 # this is an inlined copy of async_pool 541 # this is an inlined copy of async_pool
540 my $coro = (pop @pool or new Coro \&pool_handler); 542 my $coro = (pop @async_pool) || new Coro \&pool_handler;
541 543
542 $coro->{_invoke} = $cb; 544 $coro->{_invoke} = $cb;
543 $coro->ready; 545 $coro->ready;
544 cede; # for short-lived callbacks, this reduces pressure on the coro pool 546 cede; # for short-lived callbacks, this reduces pressure on the coro pool
545 } 547 }

Diff Legend

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