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

Comparing Coro/Coro.pm (file contents):
Revision 1.207 by root, Mon Nov 3 16:05:37 2008 UTC vs.
Revision 1.208 by root, Tue Nov 4 12:08:44 2008 UTC

… …
168 while @destroy; 168 while @destroy;
169 169
170 &schedule; 170 &schedule;
171 } 171 }
172}; 172};
173$manager->desc ("[coro manager]"); 173$manager->{desc} = "[coro manager]";
174$manager->prio (PRIO_MAX); 174$manager->prio (PRIO_MAX);
175 175
176=back 176=back
177 177
178=head2 SIMPLE COROUTINE CREATION 178=head2 SIMPLE COROUTINE CREATION
… …
441 } else { 441 } else {
442 $self->_cancel; 442 $self->_cancel;
443 } 443 }
444} 444}
445 445
446=item $coroutine->throw ([$scalar])
447
448If C<$throw> is specified and defined, it will be thrown as an exception
449inside the coroutine at the next convenient point in time (usually after
450it gains control at the next schedule/transfer/cede). Otherwise clears the
451exception object.
452
453The exception object will be thrown "as is" with the specified scalar in
454C<$@>, i.e. if it is a string, no line number or newline will be appended
455(unlike with C<die>).
456
457This can be used as a softer means than C<cancel> to ask a coroutine to
458end itself, although there is no guarantee that the exception will lead to
459termination, and if the exception isn't caught it might well end the whole
460program.
461
462You might also think of C<throw> as being the moral equivalent of
463C<kill>ing a coroutine with a signal (in this case, a scalar).
464
446=item $coroutine->join 465=item $coroutine->join
447 466
448Wait until the coroutine terminates and return any values given to the 467Wait until the coroutine terminates and return any values given to the
449C<terminate> or C<cancel> functions. C<join> can be called concurrently 468C<terminate> or C<cancel> functions. C<join> can be called concurrently
450from multiple coroutines, and all will be resumed and given the status 469from multiple coroutines, and all will be resumed and given the status
… …
511higher values mean lower priority, just as in unix). 530higher values mean lower priority, just as in unix).
512 531
513=item $olddesc = $coroutine->desc ($newdesc) 532=item $olddesc = $coroutine->desc ($newdesc)
514 533
515Sets (or gets in case the argument is missing) the description for this 534Sets (or gets in case the argument is missing) the description for this
516coroutine. This is just a free-form string you can associate with a coroutine. 535coroutine. This is just a free-form string you can associate with a
536coroutine.
517 537
518This method simply sets the C<< $coroutine->{desc} >> member to the given string. You 538This method simply sets the C<< $coroutine->{desc} >> member to the given
519can modify this member directly if you wish. 539string. You can modify this member directly if you wish.
520
521=item $coroutine->throw ([$scalar])
522
523If C<$throw> is specified and defined, it will be thrown as an exception
524inside the coroutine at the next convinient point in time (usually after
525it gains control at the next schedule/transfer/cede). Otherwise clears the
526exception object.
527
528The exception object will be thrown "as is" with the specified scalar in
529C<$@>, i.e. if it is a string, no line number or newline will be appended
530(unlike with C<die>).
531
532This can be used as a softer means than C<cancel> to ask a coroutine to
533end itself, although there is no guarentee that the exception will lead to
534termination, and if the exception isn't caught it might well end the whole
535program.
536 540
537=cut 541=cut
538 542
539sub desc { 543sub desc {
540 my $old = $_[0]{desc}; 544 my $old = $_[0]{desc};
… …
642 cede; # for short-lived callbacks, this reduces pressure on the coro pool 646 cede; # for short-lived callbacks, this reduces pressure on the coro pool
643 } 647 }
644 schedule; # sleep well 648 schedule; # sleep well
645 } 649 }
646}; 650};
647$unblock_scheduler->desc ("[unblock_sub scheduler]"); 651$unblock_scheduler->{desc} = "[unblock_sub scheduler]";
648 652
649sub unblock_sub(&) { 653sub unblock_sub(&) {
650 my $cb = shift; 654 my $cb = shift;
651 655
652 sub { 656 sub {

Diff Legend

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