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.270 by root, Thu Oct 1 23:50:23 2009 UTC vs.
Revision 1.274 by root, Sat Dec 12 01:30:26 2009 UTC

… …
81 81
82our $idle; # idle handler 82our $idle; # idle handler
83our $main; # main coro 83our $main; # main coro
84our $current; # current coro 84our $current; # current coro
85 85
86our $VERSION = 5.17; 86our $VERSION = 5.21;
87 87
88our @EXPORT = qw(async async_pool cede schedule terminate current unblock_sub); 88our @EXPORT = qw(async async_pool cede schedule terminate current unblock_sub rouse_cb rouse_wait);
89our %EXPORT_TAGS = ( 89our %EXPORT_TAGS = (
90 prio => [qw(PRIO_MAX PRIO_HIGH PRIO_NORMAL PRIO_LOW PRIO_IDLE PRIO_MIN)], 90 prio => [qw(PRIO_MAX PRIO_HIGH PRIO_NORMAL PRIO_LOW PRIO_IDLE PRIO_MIN)],
91); 91);
92our @EXPORT_OK = (@{$EXPORT_TAGS{prio}}, qw(nready)); 92our @EXPORT_OK = (@{$EXPORT_TAGS{prio}}, qw(nready));
93 93
… …
665venerable L<Event|Event> module) are not thread-safe (a weaker form 665venerable L<Event|Event> module) are not thread-safe (a weaker form
666of reentrancy). This means you must not block within event callbacks, 666of reentrancy). This means you must not block within event callbacks,
667otherwise you might suffer from crashes or worse. The only event library 667otherwise you might suffer from crashes or worse. The only event library
668currently known that is safe to use without C<unblock_sub> is L<EV>. 668currently known that is safe to use without C<unblock_sub> is L<EV>.
669 669
670Coro will try to catch you when you block in the event loop
671("FATAL:$Coro::IDLE blocked itself"), but this is just best effort and
672only works when you do not run your own event loop.
673
670This function allows your callbacks to block by executing them in another 674This function allows your callbacks to block by executing them in another
671coro where it is safe to block. One example where blocking is handy 675coro where it is safe to block. One example where blocking is handy
672is when you use the L<Coro::AIO|Coro::AIO> functions to save results to 676is when you use the L<Coro::AIO|Coro::AIO> functions to save results to
673disk, for example. 677disk, for example.
674 678
… …
715 unshift @unblock_queue, [$cb, @_]; 719 unshift @unblock_queue, [$cb, @_];
716 $unblock_scheduler->ready; 720 $unblock_scheduler->ready;
717 } 721 }
718} 722}
719 723
720=item $cb = Coro::rouse_cb 724=item $cb = rouse_cb
721 725
722Create and return a "rouse callback". That's a code reference that, 726Create and return a "rouse callback". That's a code reference that,
723when called, will remember a copy of its arguments and notify the owner 727when called, will remember a copy of its arguments and notify the owner
724coro of the callback. 728coro of the callback.
725 729
726See the next function. 730See the next function.
727 731
728=item @args = Coro::rouse_wait [$cb] 732=item @args = rouse_wait [$cb]
729 733
730Wait for the specified rouse callback (or the last one that was created in 734Wait for the specified rouse callback (or the last one that was created in
731this coro). 735this coro).
732 736
733As soon as the callback is invoked (or when the callback was invoked 737As soon as the callback is invoked (or when the callback was invoked
… …
830the windows process emulation enabled under unix roughly halves perl 834the windows process emulation enabled under unix roughly halves perl
831performance, even when not used. 835performance, even when not used.
832 836
833=item coro switching is not signal safe 837=item coro switching is not signal safe
834 838
835You must not switch to another coro from within a signal handler 839You must not switch to another coro from within a signal handler (only
836(only relevant with %SIG - most event libraries provide safe signals). 840relevant with %SIG - most event libraries provide safe signals), I<unless>
841you are sure you are not interrupting a Coro function.
837 842
838That means you I<MUST NOT> call any function that might "block" the 843That means you I<MUST NOT> call any function that might "block" the
839current coro - C<cede>, C<schedule> C<< Coro::Semaphore->down >> or 844current coro - C<cede>, C<schedule> C<< Coro::Semaphore->down >> or
840anything that calls those. Everything else, including calling C<ready>, 845anything that calls those. Everything else, including calling C<ready>,
841works. 846works.

Diff Legend

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