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

Comparing AnyEvent/lib/AnyEvent.pm (file contents):
Revision 1.265 by root, Wed Jul 29 13:10:58 2009 UTC vs.
Revision 1.296 by root, Tue Nov 17 01:19:49 2009 UTC

181my variables are only visible after the statement in which they are 181my variables are only visible after the statement in which they are
182declared. 182declared.
183 183
184=head2 I/O WATCHERS 184=head2 I/O WATCHERS
185 185
186 $w = AnyEvent->io (
187 fh => <filehandle_or_fileno>,
188 poll => <"r" or "w">,
189 cb => <callback>,
190 );
191
186You can create an I/O watcher by calling the C<< AnyEvent->io >> method 192You can create an I/O watcher by calling the C<< AnyEvent->io >> method
187with the following mandatory key-value pairs as arguments: 193with the following mandatory key-value pairs as arguments:
188 194
189C<fh> is the Perl I<file handle> (or a naked file descriptor) to watch 195C<fh> is the Perl I<file handle> (or a naked file descriptor) to watch
190for events (AnyEvent might or might not keep a reference to this file 196for events (AnyEvent might or might not keep a reference to this file
219 undef $w; 225 undef $w;
220 }); 226 });
221 227
222=head2 TIME WATCHERS 228=head2 TIME WATCHERS
223 229
230 $w = AnyEvent->timer (after => <seconds>, cb => <callback>);
231
232 $w = AnyEvent->timer (
233 after => <fractional_seconds>,
234 interval => <fractional_seconds>,
235 cb => <callback>,
236 );
237
224You can create a time watcher by calling the C<< AnyEvent->timer >> 238You can create a time watcher by calling the C<< AnyEvent->timer >>
225method with the following mandatory arguments: 239method with the following mandatory arguments:
226 240
227C<after> specifies after how many seconds (fractional values are 241C<after> specifies after how many seconds (fractional values are
228supported) the callback should be invoked. C<cb> is the callback to invoke 242supported) the callback should be invoked. C<cb> is the callback to invoke
349might affect timers and time-outs. 363might affect timers and time-outs.
350 364
351When this is the case, you can call this method, which will update the 365When this is the case, you can call this method, which will update the
352event loop's idea of "current time". 366event loop's idea of "current time".
353 367
368A typical example would be a script in a web server (e.g. C<mod_perl>) -
369when mod_perl executes the script, then the event loop will have the wrong
370idea about the "current time" (being potentially far in the past, when the
371script ran the last time). In that case you should arrange a call to C<<
372AnyEvent->now_update >> each time the web server process wakes up again
373(e.g. at the start of your script, or in a handler).
374
354Note that updating the time I<might> cause some events to be handled. 375Note that updating the time I<might> cause some events to be handled.
355 376
356=back 377=back
357 378
358=head2 SIGNAL WATCHERS 379=head2 SIGNAL WATCHERS
380
381 $w = AnyEvent->signal (signal => <uppercase_signal_name>, cb => <callback>);
359 382
360You can watch for signals using a signal watcher, C<signal> is the signal 383You can watch for signals using a signal watcher, C<signal> is the signal
361I<name> in uppercase and without any C<SIG> prefix, C<cb> is the Perl 384I<name> in uppercase and without any C<SIG> prefix, C<cb> is the Perl
362callback to be invoked whenever a signal occurs. 385callback to be invoked whenever a signal occurs.
363 386
383 my $w = AnyEvent->signal (signal => "INT", cb => sub { exit 1 }); 406 my $w = AnyEvent->signal (signal => "INT", cb => sub { exit 1 });
384 407
385=head3 Signal Races, Delays and Workarounds 408=head3 Signal Races, Delays and Workarounds
386 409
387Many event loops (e.g. Glib, Tk, Qt, IO::Async) do not support attaching 410Many event loops (e.g. Glib, Tk, Qt, IO::Async) do not support attaching
388callbacks to signals in a generic way, which is a pity, as you cannot do 411callbacks to signals in a generic way, which is a pity, as you cannot
389race-free signal handling in perl. AnyEvent will try to do it's best, but 412do race-free signal handling in perl, requiring C libraries for
413this. AnyEvent will try to do it's best, which means in some cases,
390in some cases, signals will be delayed. The maximum time a signal might 414signals will be delayed. The maximum time a signal might be delayed is
391be delayed is specified in C<$AnyEvent::MAX_SIGNAL_LATENCY> (default: 10 415specified in C<$AnyEvent::MAX_SIGNAL_LATENCY> (default: 10 seconds). This
392seconds). This variable can be changed only before the first signal 416variable can be changed only before the first signal watcher is created,
393watcher is created, and should be left alone otherwise. Higher values 417and should be left alone otherwise. This variable determines how often
418AnyEvent polls for signals (in case a wake-up was missed). Higher values
394will cause fewer spurious wake-ups, which is better for power and CPU 419will cause fewer spurious wake-ups, which is better for power and CPU
420saving.
421
395saving. All these problems can be avoided by installing the optional 422All these problems can be avoided by installing the optional
396L<Async::Interrupt> module. This will not work with inherently broken 423L<Async::Interrupt> module, which works with most event loops. It will not
397event loops such as L<Event> or L<Event::Lib> (and not with L<POE> 424work with inherently broken event loops such as L<Event> or L<Event::Lib>
398currently, as POE does it's own workaround with one-second latency). With 425(and not with L<POE> currently, as POE does it's own workaround with
399those, you just have to suffer the delays. 426one-second latency). For those, you just have to suffer the delays.
400 427
401=head2 CHILD PROCESS WATCHERS 428=head2 CHILD PROCESS WATCHERS
429
430 $w = AnyEvent->child (pid => <process id>, cb => <callback>);
402 431
403You can also watch on a child process exit and catch its exit status. 432You can also watch on a child process exit and catch its exit status.
404 433
405The child process is specified by the C<pid> argument (one some backends, 434The child process is specified by the C<pid> argument (one some backends,
406using C<0> watches for any child process exit, on others this will 435using C<0> watches for any child process exit, on others this will
455 # do something else, then wait for process exit 484 # do something else, then wait for process exit
456 $done->recv; 485 $done->recv;
457 486
458=head2 IDLE WATCHERS 487=head2 IDLE WATCHERS
459 488
489 $w = AnyEvent->idle (cb => <callback>);
490
460Sometimes there is a need to do something, but it is not so important 491Sometimes there is a need to do something, but it is not so important
461to do it instantly, but only when there is nothing better to do. This 492to do it instantly, but only when there is nothing better to do. This
462"nothing better to do" is usually defined to be "no other events need 493"nothing better to do" is usually defined to be "no other events need
463attention by the event loop". 494attention by the event loop".
464 495
490 }); 521 });
491 }); 522 });
492 523
493=head2 CONDITION VARIABLES 524=head2 CONDITION VARIABLES
494 525
526 $cv = AnyEvent->condvar;
527
528 $cv->send (<list>);
529 my @res = $cv->recv;
530
495If you are familiar with some event loops you will know that all of them 531If you are familiar with some event loops you will know that all of them
496require you to run some blocking "loop", "run" or similar function that 532require you to run some blocking "loop", "run" or similar function that
497will actively watch for new events and call your callbacks. 533will actively watch for new events and call your callbacks.
498 534
499AnyEvent is slightly different: it expects somebody else to run the event 535AnyEvent is slightly different: it expects somebody else to run the event
563 after => 1, 599 after => 1,
564 cb => sub { $result_ready->send }, 600 cb => sub { $result_ready->send },
565 ); 601 );
566 602
567 # this "blocks" (while handling events) till the callback 603 # this "blocks" (while handling events) till the callback
568 # calls -<send 604 # calls ->send
569 $result_ready->recv; 605 $result_ready->recv;
570 606
571Example: wait for a timer, but take advantage of the fact that condition 607Example: wait for a timer, but take advantage of the fact that condition
572variables are also callable directly. 608variables are also callable directly.
573 609
637one. For example, a function that pings many hosts in parallel might want 673one. For example, a function that pings many hosts in parallel might want
638to use a condition variable for the whole process. 674to use a condition variable for the whole process.
639 675
640Every call to C<< ->begin >> will increment a counter, and every call to 676Every call to C<< ->begin >> will increment a counter, and every call to
641C<< ->end >> will decrement it. If the counter reaches C<0> in C<< ->end 677C<< ->end >> will decrement it. If the counter reaches C<0> in C<< ->end
642>>, the (last) callback passed to C<begin> will be executed. That callback 678>>, the (last) callback passed to C<begin> will be executed, passing the
643is I<supposed> to call C<< ->send >>, but that is not required. If no 679condvar as first argument. That callback is I<supposed> to call C<< ->send
644callback was set, C<send> will be called without any arguments. 680>>, but that is not required. If no group callback was set, C<send> will
681be called without any arguments.
645 682
646You can think of C<< $cv->send >> giving you an OR condition (one call 683You can think of C<< $cv->send >> giving you an OR condition (one call
647sends), while C<< $cv->begin >> and C<< $cv->end >> giving you an AND 684sends), while C<< $cv->begin >> and C<< $cv->end >> giving you an AND
648condition (all C<begin> calls must be C<end>'ed before the condvar sends). 685condition (all C<begin> calls must be C<end>'ed before the condvar sends).
649 686
676begung can potentially be zero: 713begung can potentially be zero:
677 714
678 my $cv = AnyEvent->condvar; 715 my $cv = AnyEvent->condvar;
679 716
680 my %result; 717 my %result;
681 $cv->begin (sub { $cv->send (\%result) }); 718 $cv->begin (sub { shift->send (\%result) });
682 719
683 for my $host (@list_of_hosts) { 720 for my $host (@list_of_hosts) {
684 $cv->begin; 721 $cv->begin;
685 ping_host_then_call_callback $host, sub { 722 ping_host_then_call_callback $host, sub {
686 $result{$host} = ...; 723 $result{$host} = ...;
761=item $cb = $cv->cb ($cb->($cv)) 798=item $cb = $cv->cb ($cb->($cv))
762 799
763This is a mutator function that returns the callback set and optionally 800This is a mutator function that returns the callback set and optionally
764replaces it before doing so. 801replaces it before doing so.
765 802
766The callback will be called when the condition becomes "true", i.e. when 803The callback will be called when the condition becomes (or already was)
767C<send> or C<croak> are called, with the only argument being the condition 804"true", i.e. when C<send> or C<croak> are called (or were called), with
768variable itself. Calling C<recv> inside the callback or at any later time 805the only argument being the condition variable itself. Calling C<recv>
769is guaranteed not to block. 806inside the callback or at any later time is guaranteed not to block.
770 807
771=back 808=back
772 809
773=head1 SUPPORTED EVENT LOOPS/BACKENDS 810=head1 SUPPORTED EVENT LOOPS/BACKENDS
774 811
777=over 4 814=over 4
778 815
779=item Backends that are autoprobed when no other event loop can be found. 816=item Backends that are autoprobed when no other event loop can be found.
780 817
781EV is the preferred backend when no other event loop seems to be in 818EV is the preferred backend when no other event loop seems to be in
782use. If EV is not installed, then AnyEvent will try Event, and, failing 819use. If EV is not installed, then AnyEvent will fall back to its own
783that, will fall back to its own pure-perl implementation, which is 820pure-perl implementation, which is available everywhere as it comes with
784available everywhere as it comes with AnyEvent itself. 821AnyEvent itself.
785 822
786 AnyEvent::Impl::EV based on EV (interface to libev, best choice). 823 AnyEvent::Impl::EV based on EV (interface to libev, best choice).
787 AnyEvent::Impl::Event based on Event, very stable, few glitches.
788 AnyEvent::Impl::Perl pure-perl implementation, fast and portable. 824 AnyEvent::Impl::Perl pure-perl implementation, fast and portable.
789 825
790=item Backends that are transparently being picked up when they are used. 826=item Backends that are transparently being picked up when they are used.
791 827
792These will be used when they are currently loaded when the first watcher 828These will be used when they are currently loaded when the first watcher
793is created, in which case it is assumed that the application is using 829is created, in which case it is assumed that the application is using
794them. This means that AnyEvent will automatically pick the right backend 830them. This means that AnyEvent will automatically pick the right backend
795when the main program loads an event module before anything starts to 831when the main program loads an event module before anything starts to
796create watchers. Nothing special needs to be done by the main program. 832create watchers. Nothing special needs to be done by the main program.
797 833
834 AnyEvent::Impl::Event based on Event, very stable, few glitches.
798 AnyEvent::Impl::Glib based on Glib, slow but very stable. 835 AnyEvent::Impl::Glib based on Glib, slow but very stable.
799 AnyEvent::Impl::Tk based on Tk, very broken. 836 AnyEvent::Impl::Tk based on Tk, very broken.
800 AnyEvent::Impl::EventLib based on Event::Lib, leaks memory and worse. 837 AnyEvent::Impl::EventLib based on Event::Lib, leaks memory and worse.
801 AnyEvent::Impl::POE based on POE, very slow, some limitations. 838 AnyEvent::Impl::POE based on POE, very slow, some limitations.
802 AnyEvent::Impl::Irssi used when running within irssi. 839 AnyEvent::Impl::Irssi used when running within irssi.
1076 1113
1077package AnyEvent; 1114package AnyEvent;
1078 1115
1079# basically a tuned-down version of common::sense 1116# basically a tuned-down version of common::sense
1080sub common_sense { 1117sub common_sense {
1081 # no warnings 1118 # from common:.sense 1.0
1082 ${^WARNING_BITS} ^= ${^WARNING_BITS}; 1119 ${^WARNING_BITS} = "\xfc\x3f\xf3\x00\x0f\xf3\xcf\xc0\xf3\xfc\x33\x03";
1083 # use strict vars subs 1120 # use strict vars subs
1084 $^H |= 0x00000600; 1121 $^H |= 0x00000600;
1085} 1122}
1086 1123
1087BEGIN { AnyEvent::common_sense } 1124BEGIN { AnyEvent::common_sense }
1088 1125
1089use Carp (); 1126use Carp ();
1090 1127
1091our $VERSION = 4.881; 1128our $VERSION = '5.202';
1092our $MODEL; 1129our $MODEL;
1093 1130
1094our $AUTOLOAD; 1131our $AUTOLOAD;
1095our @ISA; 1132our @ISA;
1096 1133
1122 $ENV{PERL_ANYEVENT_PROTOCOLS} || "ipv4,ipv6"; 1159 $ENV{PERL_ANYEVENT_PROTOCOLS} || "ipv4,ipv6";
1123} 1160}
1124 1161
1125my @models = ( 1162my @models = (
1126 [EV:: => AnyEvent::Impl::EV:: , 1], 1163 [EV:: => AnyEvent::Impl::EV:: , 1],
1127 [Event:: => AnyEvent::Impl::Event::, 1],
1128 [AnyEvent::Impl::Perl:: => AnyEvent::Impl::Perl:: , 1], 1164 [AnyEvent::Impl::Perl:: => AnyEvent::Impl::Perl:: , 1],
1129 # everything below here will not (normally) be autoprobed 1165 # everything below here will not (normally) be autoprobed
1130 # as the pureperl backend should work everywhere 1166 # as the pureperl backend should work everywhere
1131 # and is usually faster 1167 # and is usually faster
1168 [Event:: => AnyEvent::Impl::Event::, 1],
1132 [Glib:: => AnyEvent::Impl::Glib:: , 1], # becomes extremely slow with many watchers 1169 [Glib:: => AnyEvent::Impl::Glib:: , 1], # becomes extremely slow with many watchers
1133 [Event::Lib:: => AnyEvent::Impl::EventLib::], # too buggy 1170 [Event::Lib:: => AnyEvent::Impl::EventLib::], # too buggy
1134 [Irssi:: => AnyEvent::Impl::Irssi::], # Irssi has a bogus "Event" package 1171 [Irssi:: => AnyEvent::Impl::Irssi::], # Irssi has a bogus "Event" package
1135 [Tk:: => AnyEvent::Impl::Tk::], # crashes with many handles 1172 [Tk:: => AnyEvent::Impl::Tk::], # crashes with many handles
1136 [Qt:: => AnyEvent::Impl::Qt::], # requires special main program 1173 [Qt:: => AnyEvent::Impl::Qt::], # requires special main program
1139 [Prima:: => AnyEvent::Impl::POE::], 1176 [Prima:: => AnyEvent::Impl::POE::],
1140 # IO::Async is just too broken - we would need workarounds for its 1177 # IO::Async is just too broken - we would need workarounds for its
1141 # byzantine signal and broken child handling, among others. 1178 # byzantine signal and broken child handling, among others.
1142 # IO::Async is rather hard to detect, as it doesn't have any 1179 # IO::Async is rather hard to detect, as it doesn't have any
1143 # obvious default class. 1180 # obvious default class.
1144# [0, IO::Async:: => AnyEvent::Impl::IOAsync::], # requires special main program 1181 [IO::Async:: => AnyEvent::Impl::IOAsync::], # requires special main program
1145# [0, IO::Async::Loop:: => AnyEvent::Impl::IOAsync::], # requires special main program 1182 [IO::Async::Loop:: => AnyEvent::Impl::IOAsync::], # requires special main program
1146# [0, IO::Async::Notifier:: => AnyEvent::Impl::IOAsync::], # requires special main program 1183 [IO::Async::Notifier:: => AnyEvent::Impl::IOAsync::], # requires special main program
1184 [AnyEvent::Impl::IOAsync:: => AnyEvent::Impl::IOAsync::], # requires special main program
1147); 1185);
1148 1186
1149our %method = map +($_ => 1), 1187our %method = map +($_ => 1),
1150 qw(io timer time now now_update signal child idle condvar one_event DESTROY); 1188 qw(io timer time now now_update signal child idle condvar one_event DESTROY);
1151 1189
1258 # we assume CLOEXEC is already set by perl in all important cases 1296 # we assume CLOEXEC is already set by perl in all important cases
1259 1297
1260 ($fh2, $rw) 1298 ($fh2, $rw)
1261} 1299}
1262 1300
1301=head1 SIMPLIFIED AE API
1302
1303Starting with version 5.0, AnyEvent officially supports a second, much
1304simpler, API that is designed to reduce the calling, typing and memory
1305overhead.
1306
1307See the L<AE> manpage for details.
1308
1309=cut
1310
1311package AE;
1312
1313our $VERSION = $AnyEvent::VERSION;
1314
1315sub io($$$) {
1316 AnyEvent->io (fh => $_[0], poll => $_[1] ? "w" : "r", cb => $_[2])
1317}
1318
1319sub timer($$$) {
1320 AnyEvent->timer (after => $_[0], interval => $_[1], cb => $_[2])
1321}
1322
1323sub signal($$) {
1324 AnyEvent->signal (signal => $_[0], cb => $_[1])
1325}
1326
1327sub child($$) {
1328 AnyEvent->child (pid => $_[0], cb => $_[1])
1329}
1330
1331sub idle($) {
1332 AnyEvent->idle (cb => $_[0])
1333}
1334
1335sub cv(;&) {
1336 AnyEvent->condvar (@_ ? (cb => $_[0]) : ())
1337}
1338
1339sub now() {
1340 AnyEvent->now
1341}
1342
1343sub now_update() {
1344 AnyEvent->now_update
1345}
1346
1347sub time() {
1348 AnyEvent->time
1349}
1350
1263package AnyEvent::Base; 1351package AnyEvent::Base;
1264 1352
1265# default implementations for many methods 1353# default implementations for many methods
1266 1354
1267sub _time { 1355sub _time() {
1268 # probe for availability of Time::HiRes 1356 # probe for availability of Time::HiRes
1269 if (eval "use Time::HiRes (); Time::HiRes::time (); 1") { 1357 if (eval "use Time::HiRes (); Time::HiRes::time (); 1") {
1270 warn "AnyEvent: using Time::HiRes for sub-second timing accuracy.\n" if $VERBOSE >= 8; 1358 warn "AnyEvent: using Time::HiRes for sub-second timing accuracy.\n" if $VERBOSE >= 8;
1271 *_time = \&Time::HiRes::time; 1359 *_time = \&Time::HiRes::time;
1272 # if (eval "use POSIX (); (POSIX::times())... 1360 # if (eval "use POSIX (); (POSIX::times())...
1292 1380
1293our $HAVE_ASYNC_INTERRUPT; 1381our $HAVE_ASYNC_INTERRUPT;
1294 1382
1295sub _have_async_interrupt() { 1383sub _have_async_interrupt() {
1296 $HAVE_ASYNC_INTERRUPT = 1*(!$ENV{PERL_ANYEVENT_AVOID_ASYNC_INTERRUPT} 1384 $HAVE_ASYNC_INTERRUPT = 1*(!$ENV{PERL_ANYEVENT_AVOID_ASYNC_INTERRUPT}
1297 && eval "use Async::Interrupt 1.0 (); 1") 1385 && eval "use Async::Interrupt 1.02 (); 1")
1298 unless defined $HAVE_ASYNC_INTERRUPT; 1386 unless defined $HAVE_ASYNC_INTERRUPT;
1299 1387
1300 $HAVE_ASYNC_INTERRUPT 1388 $HAVE_ASYNC_INTERRUPT
1301} 1389}
1302 1390
1305our ($SIG_COUNT, $SIG_TW); 1393our ($SIG_COUNT, $SIG_TW);
1306 1394
1307sub _signal_exec { 1395sub _signal_exec {
1308 $HAVE_ASYNC_INTERRUPT 1396 $HAVE_ASYNC_INTERRUPT
1309 ? $SIGPIPE_R->drain 1397 ? $SIGPIPE_R->drain
1310 : sysread $SIGPIPE_R, my $dummy, 9; 1398 : sysread $SIGPIPE_R, (my $dummy), 9;
1311 1399
1312 while (%SIG_EV) { 1400 while (%SIG_EV) {
1313 for (keys %SIG_EV) { 1401 for (keys %SIG_EV) {
1314 delete $SIG_EV{$_}; 1402 delete $SIG_EV{$_};
1315 $_->() for values %{ $SIG_CB{$_} || {} }; 1403 $_->() for values %{ $SIG_CB{$_} || {} };
1319 1407
1320# install a dummy wakeup watcher to reduce signal catching latency 1408# install a dummy wakeup watcher to reduce signal catching latency
1321sub _sig_add() { 1409sub _sig_add() {
1322 unless ($SIG_COUNT++) { 1410 unless ($SIG_COUNT++) {
1323 # try to align timer on a full-second boundary, if possible 1411 # try to align timer on a full-second boundary, if possible
1324 my $NOW = AnyEvent->now; 1412 my $NOW = AE::now;
1325 1413
1326 $SIG_TW = AnyEvent->timer ( 1414 $SIG_TW = AE::timer
1327 after => $MAX_SIGNAL_LATENCY - ($NOW - int $NOW), 1415 $MAX_SIGNAL_LATENCY - ($NOW - int $NOW),
1328 interval => $MAX_SIGNAL_LATENCY, 1416 $MAX_SIGNAL_LATENCY,
1329 cb => sub { }, # just for the PERL_ASYNC_CHECK 1417 sub { } # just for the PERL_ASYNC_CHECK
1330 ); 1418 ;
1331 } 1419 }
1332} 1420}
1333 1421
1334sub _sig_del { 1422sub _sig_del {
1335 undef $SIG_TW 1423 undef $SIG_TW
1372 # probe for availability of Async::Interrupt 1460 # probe for availability of Async::Interrupt
1373 if (_have_async_interrupt) { 1461 if (_have_async_interrupt) {
1374 warn "AnyEvent: using Async::Interrupt for race-free signal handling.\n" if $VERBOSE >= 8; 1462 warn "AnyEvent: using Async::Interrupt for race-free signal handling.\n" if $VERBOSE >= 8;
1375 1463
1376 $SIGPIPE_R = new Async::Interrupt::EventPipe; 1464 $SIGPIPE_R = new Async::Interrupt::EventPipe;
1377 $SIG_IO = AnyEvent->io (fh => $SIGPIPE_R->fileno, poll => "r", cb => \&_signal_exec); 1465 $SIG_IO = AE::io $SIGPIPE_R->fileno, 0, \&_signal_exec;
1378 1466
1379 } else { 1467 } else {
1380 warn "AnyEvent: using emulated perl signal handling with latency timer.\n" if $VERBOSE >= 8; 1468 warn "AnyEvent: using emulated perl signal handling with latency timer.\n" if $VERBOSE >= 8;
1381 1469
1382 require Fcntl; 1470 require Fcntl;
1398 } 1486 }
1399 1487
1400 $SIGPIPE_R 1488 $SIGPIPE_R
1401 or Carp::croak "AnyEvent: unable to create a signal reporting pipe: $!\n"; 1489 or Carp::croak "AnyEvent: unable to create a signal reporting pipe: $!\n";
1402 1490
1403 $SIG_IO = AnyEvent->io (fh => $SIGPIPE_R, poll => "r", cb => \&_signal_exec); 1491 $SIG_IO = AE::io $SIGPIPE_R, 0, \&_signal_exec;
1404 } 1492 }
1405 1493
1406 *signal = sub { 1494 *signal = sub {
1407 my (undef, %arg) = @_; 1495 my (undef, %arg) = @_;
1408 1496
1497 $WNOHANG ||= $^O =~ /^(?:openbsd|netbsd|linux|freebsd|cygwin|MSWin32)$/ 1585 $WNOHANG ||= $^O =~ /^(?:openbsd|netbsd|linux|freebsd|cygwin|MSWin32)$/
1498 ? 1 1586 ? 1
1499 : eval { local $SIG{__DIE__}; require POSIX; &POSIX::WNOHANG } || 1; 1587 : eval { local $SIG{__DIE__}; require POSIX; &POSIX::WNOHANG } || 1;
1500 1588
1501 unless ($CHLD_W) { 1589 unless ($CHLD_W) {
1502 $CHLD_W = AnyEvent->signal (signal => 'CHLD', cb => \&_sigchld); 1590 $CHLD_W = AE::signal CHLD => \&_sigchld;
1503 # child could be a zombie already, so make at least one round 1591 # child could be a zombie already, so make at least one round
1504 &_sigchld; 1592 &_sigchld;
1505 } 1593 }
1506 1594
1507 bless [$pid, $arg{cb}], "AnyEvent::Base::child" 1595 bless [$pid, $arg{cb}], "AnyEvent::Base::child"
1533 # never use more then 50% of the time for the idle watcher, 1621 # never use more then 50% of the time for the idle watcher,
1534 # within some limits 1622 # within some limits
1535 $w = 0.0001 if $w < 0.0001; 1623 $w = 0.0001 if $w < 0.0001;
1536 $w = 5 if $w > 5; 1624 $w = 5 if $w > 5;
1537 1625
1538 $w = AnyEvent->timer (after => $w, cb => $rcb); 1626 $w = AE::timer $w, 0, $rcb;
1539 } else { 1627 } else {
1540 # clean up... 1628 # clean up...
1541 undef $w; 1629 undef $w;
1542 undef $rcb; 1630 undef $rcb;
1543 } 1631 }
1544 }; 1632 };
1545 1633
1546 $w = AnyEvent->timer (after => 0.05, cb => $rcb); 1634 $w = AE::timer 0.05, 0, $rcb;
1547 1635
1548 bless \\$cb, "AnyEvent::Base::idle" 1636 bless \\$cb, "AnyEvent::Base::idle"
1549} 1637}
1550 1638
1551sub AnyEvent::Base::idle::DESTROY { 1639sub AnyEvent::Base::idle::DESTROY {
1605 Carp::croak $_[0]{_ae_croak} if $_[0]{_ae_croak}; 1693 Carp::croak $_[0]{_ae_croak} if $_[0]{_ae_croak};
1606 wantarray ? @{ $_[0]{_ae_sent} } : $_[0]{_ae_sent}[0] 1694 wantarray ? @{ $_[0]{_ae_sent} } : $_[0]{_ae_sent}[0]
1607} 1695}
1608 1696
1609sub cb { 1697sub cb {
1610 $_[0]{_ae_cb} = $_[1] if @_ > 1; 1698 my $cv = shift;
1699
1700 @_
1701 and $cv->{_ae_cb} = shift
1702 and $cv->{_ae_sent}
1703 and (delete $cv->{_ae_cb})->($cv);
1704
1611 $_[0]{_ae_cb} 1705 $cv->{_ae_cb}
1612} 1706}
1613 1707
1614sub begin { 1708sub begin {
1615 ++$_[0]{_ae_counter}; 1709 ++$_[0]{_ae_counter};
1616 $_[0]{_ae_end_cb} = $_[1] if @_ > 1; 1710 $_[0]{_ae_end_cb} = $_[1] if @_ > 1;
1825 warn "read: $input\n"; # output what has been read 1919 warn "read: $input\n"; # output what has been read
1826 $cv->send if $input =~ /^q/i; # quit program if /^q/i 1920 $cv->send if $input =~ /^q/i; # quit program if /^q/i
1827 }, 1921 },
1828 ); 1922 );
1829 1923
1830 my $time_watcher; # can only be used once
1831
1832 sub new_timer {
1833 $timer = AnyEvent->timer (after => 1, cb => sub { 1924 my $time_watcher = AnyEvent->timer (after => 1, interval => 1, cb => sub {
1834 warn "timeout\n"; # print 'timeout' about every second 1925 warn "timeout\n"; # print 'timeout' at most every second
1835 &new_timer; # and restart the time
1836 }); 1926 });
1837 }
1838
1839 new_timer; # create first timer
1840 1927
1841 $cv->recv; # wait until user enters /^q/i 1928 $cv->recv; # wait until user enters /^q/i
1842 1929
1843=head1 REAL-WORLD EXAMPLE 1930=head1 REAL-WORLD EXAMPLE
1844 1931
1975through AnyEvent. The benchmark creates a lot of timers (with a zero 2062through AnyEvent. The benchmark creates a lot of timers (with a zero
1976timeout) and I/O watchers (watching STDOUT, a pty, to become writable, 2063timeout) and I/O watchers (watching STDOUT, a pty, to become writable,
1977which it is), lets them fire exactly once and destroys them again. 2064which it is), lets them fire exactly once and destroys them again.
1978 2065
1979Source code for this benchmark is found as F<eg/bench> in the AnyEvent 2066Source code for this benchmark is found as F<eg/bench> in the AnyEvent
1980distribution. 2067distribution. It uses the L<AE> interface, which makes a real difference
2068for the EV and Perl backends only.
1981 2069
1982=head3 Explanation of the columns 2070=head3 Explanation of the columns
1983 2071
1984I<watcher> is the number of event watchers created/destroyed. Since 2072I<watcher> is the number of event watchers created/destroyed. Since
1985different event models feature vastly different performances, each event 2073different event models feature vastly different performances, each event
2006watcher. 2094watcher.
2007 2095
2008=head3 Results 2096=head3 Results
2009 2097
2010 name watchers bytes create invoke destroy comment 2098 name watchers bytes create invoke destroy comment
2011 EV/EV 400000 224 0.47 0.35 0.27 EV native interface 2099 EV/EV 100000 223 0.47 0.43 0.27 EV native interface
2012 EV/Any 100000 224 2.88 0.34 0.27 EV + AnyEvent watchers 2100 EV/Any 100000 223 0.48 0.42 0.26 EV + AnyEvent watchers
2013 CoroEV/Any 100000 224 2.85 0.35 0.28 coroutines + Coro::Signal 2101 Coro::EV/Any 100000 223 0.47 0.42 0.26 coroutines + Coro::Signal
2014 Perl/Any 100000 452 4.13 0.73 0.95 pure perl implementation 2102 Perl/Any 100000 431 2.70 0.74 0.92 pure perl implementation
2015 Event/Event 16000 517 32.20 31.80 0.81 Event native interface 2103 Event/Event 16000 516 31.16 31.84 0.82 Event native interface
2016 Event/Any 16000 590 35.85 31.55 1.06 Event + AnyEvent watchers 2104 Event/Any 16000 1203 42.61 34.79 1.80 Event + AnyEvent watchers
2017 IOAsync/Any 16000 989 38.10 32.77 11.13 via IO::Async::Loop::IO_Poll 2105 IOAsync/Any 16000 1911 41.92 27.45 16.81 via IO::Async::Loop::IO_Poll
2018 IOAsync/Any 16000 990 37.59 29.50 10.61 via IO::Async::Loop::Epoll 2106 IOAsync/Any 16000 1726 40.69 26.37 15.25 via IO::Async::Loop::Epoll
2019 Glib/Any 16000 1357 102.33 12.31 51.00 quadratic behaviour 2107 Glib/Any 16000 1118 89.00 12.57 51.17 quadratic behaviour
2020 Tk/Any 2000 1860 27.20 66.31 14.00 SEGV with >> 2000 watchers 2108 Tk/Any 2000 1346 20.96 10.75 8.00 SEGV with >> 2000 watchers
2021 POE/Event 2000 6328 109.99 751.67 14.02 via POE::Loop::Event 2109 POE/Any 2000 6951 108.97 795.32 14.24 via POE::Loop::Event
2022 POE/Select 2000 6027 94.54 809.13 579.80 via POE::Loop::Select 2110 POE/Any 2000 6648 94.79 774.40 575.51 via POE::Loop::Select
2023 2111
2024=head3 Discussion 2112=head3 Discussion
2025 2113
2026The benchmark does I<not> measure scalability of the event loop very 2114The benchmark does I<not> measure scalability of the event loop very
2027well. For example, a select-based event loop (such as the pure perl one) 2115well. For example, a select-based event loop (such as the pure perl one)
2039benchmark machine, handling an event takes roughly 1600 CPU cycles with 2127benchmark machine, handling an event takes roughly 1600 CPU cycles with
2040EV, 3100 CPU cycles with AnyEvent's pure perl loop and almost 3000000 CPU 2128EV, 3100 CPU cycles with AnyEvent's pure perl loop and almost 3000000 CPU
2041cycles with POE. 2129cycles with POE.
2042 2130
2043C<EV> is the sole leader regarding speed and memory use, which are both 2131C<EV> is the sole leader regarding speed and memory use, which are both
2044maximal/minimal, respectively. Even when going through AnyEvent, it uses 2132maximal/minimal, respectively. When using the L<AE> API there is zero
2133overhead (when going through the AnyEvent API create is about 5-6 times
2134slower, with other times being equal, so still uses far less memory than
2045far less memory than any other event loop and is still faster than Event 2135any other event loop and is still faster than Event natively).
2046natively.
2047 2136
2048The pure perl implementation is hit in a few sweet spots (both the 2137The pure perl implementation is hit in a few sweet spots (both the
2049constant timeout and the use of a single fd hit optimisations in the perl 2138constant timeout and the use of a single fd hit optimisations in the perl
2050interpreter and the backend itself). Nevertheless this shows that it 2139interpreter and the backend itself). Nevertheless this shows that it
2051adds very little overhead in itself. Like any select-based backend its 2140adds very little overhead in itself. Like any select-based backend its
2125In this benchmark, we use 10000 socket pairs (20000 sockets), of which 100 2214In this benchmark, we use 10000 socket pairs (20000 sockets), of which 100
2126(1%) are active. This mirrors the activity of large servers with many 2215(1%) are active. This mirrors the activity of large servers with many
2127connections, most of which are idle at any one point in time. 2216connections, most of which are idle at any one point in time.
2128 2217
2129Source code for this benchmark is found as F<eg/bench2> in the AnyEvent 2218Source code for this benchmark is found as F<eg/bench2> in the AnyEvent
2130distribution. 2219distribution. It uses the L<AE> interface, which makes a real difference
2220for the EV and Perl backends only.
2131 2221
2132=head3 Explanation of the columns 2222=head3 Explanation of the columns
2133 2223
2134I<sockets> is the number of sockets, and twice the number of "servers" (as 2224I<sockets> is the number of sockets, and twice the number of "servers" (as
2135each server has a read and write socket end). 2225each server has a read and write socket end).
2143a new one that moves the timeout into the future. 2233a new one that moves the timeout into the future.
2144 2234
2145=head3 Results 2235=head3 Results
2146 2236
2147 name sockets create request 2237 name sockets create request
2148 EV 20000 69.01 11.16 2238 EV 20000 62.66 7.99
2149 Perl 20000 73.32 35.87 2239 Perl 20000 68.32 32.64
2150 IOAsync 20000 157.00 98.14 epoll 2240 IOAsync 20000 174.06 101.15 epoll
2151 IOAsync 20000 159.31 616.06 poll 2241 IOAsync 20000 174.67 610.84 poll
2152 Event 20000 212.62 257.32 2242 Event 20000 202.69 242.91
2153 Glib 20000 651.16 1896.30 2243 Glib 20000 557.01 1689.52
2154 POE 20000 349.67 12317.24 uses POE::Loop::Event 2244 POE 20000 341.54 12086.32 uses POE::Loop::Event
2155 2245
2156=head3 Discussion 2246=head3 Discussion
2157 2247
2158This benchmark I<does> measure scalability and overall performance of the 2248This benchmark I<does> measure scalability and overall performance of the
2159particular event loop. 2249particular event loop.
2285As you can see, the AnyEvent + EV combination even beats the 2375As you can see, the AnyEvent + EV combination even beats the
2286hand-optimised "raw sockets benchmark", while AnyEvent + its pure perl 2376hand-optimised "raw sockets benchmark", while AnyEvent + its pure perl
2287backend easily beats IO::Lambda and POE. 2377backend easily beats IO::Lambda and POE.
2288 2378
2289And even the 100% non-blocking version written using the high-level (and 2379And even the 100% non-blocking version written using the high-level (and
2290slow :) L<AnyEvent::Handle> abstraction beats both POE and IO::Lambda by a 2380slow :) L<AnyEvent::Handle> abstraction beats both POE and IO::Lambda
2291large margin, even though it does all of DNS, tcp-connect and socket I/O 2381higher level ("unoptimised") abstractions by a large margin, even though
2292in a non-blocking way. 2382it does all of DNS, tcp-connect and socket I/O in a non-blocking way.
2293 2383
2294The two AnyEvent benchmarks programs can be found as F<eg/ae0.pl> and 2384The two AnyEvent benchmarks programs can be found as F<eg/ae0.pl> and
2295F<eg/ae2.pl> in the AnyEvent distribution, the remaining benchmarks are 2385F<eg/ae2.pl> in the AnyEvent distribution, the remaining benchmarks are
2296part of the IO::lambda distribution and were used without any changes. 2386part of the IO::Lambda distribution and were used without any changes.
2297 2387
2298 2388
2299=head1 SIGNALS 2389=head1 SIGNALS
2300 2390
2301AnyEvent currently installs handlers for these signals: 2391AnyEvent currently installs handlers for these signals:
2390lot less memory), but otherwise doesn't affect guard operation much. It is 2480lot less memory), but otherwise doesn't affect guard operation much. It is
2391purely used for performance. 2481purely used for performance.
2392 2482
2393=item L<JSON> and L<JSON::XS> 2483=item L<JSON> and L<JSON::XS>
2394 2484
2395This module is required when you want to read or write JSON data via 2485One of these modules is required when you want to read or write JSON data
2396L<AnyEvent::Handle>. It is also written in pure-perl, but can take 2486via L<AnyEvent::Handle>. It is also written in pure-perl, but can take
2397advantage of the ultra-high-speed L<JSON::XS> module when it is installed. 2487advantage of the ultra-high-speed L<JSON::XS> module when it is installed.
2398 2488
2399In fact, L<AnyEvent::Handle> will use L<JSON::XS> by default if it is 2489In fact, L<AnyEvent::Handle> will use L<JSON::XS> by default if it is
2400installed. 2490installed.
2401 2491

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines