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.305 by root, Sun Dec 13 05:13:15 2009 UTC vs.
Revision 1.311 by root, Wed Feb 10 13:33:44 2010 UTC

503 503
504=head2 IDLE WATCHERS 504=head2 IDLE WATCHERS
505 505
506 $w = AnyEvent->idle (cb => <callback>); 506 $w = AnyEvent->idle (cb => <callback>);
507 507
508Sometimes there is a need to do something, but it is not so important 508Repeatedly invoke the callback after the process becomes idle, until
509to do it instantly, but only when there is nothing better to do. This 509either the watcher is destroyed or new events have been detected.
510"nothing better to do" is usually defined to be "no other events need
511attention by the event loop".
512 510
513Idle watchers ideally get invoked when the event loop has nothing 511Idle watchers are useful when there is a need to do something, but it
514better to do, just before it would block the process to wait for new 512is not so important (or wise) to do it instantly. The callback will be
515events. Instead of blocking, the idle watcher is invoked. 513invoked only when there is "nothing better to do", which is usually
514defined as "all outstanding events have been handled and no new events
515have been detected". That means that idle watchers ideally get invoked
516when the event loop has just polled for new events but none have been
517detected. Instead of blocking to wait for more events, the idle watchers
518will be invoked.
516 519
517Most event loops unfortunately do not really support idle watchers (only 520Unfortunately, most event loops do not really support idle watchers (only
518EV, Event and Glib do it in a usable fashion) - for the rest, AnyEvent 521EV, Event and Glib do it in a usable fashion) - for the rest, AnyEvent
519will simply call the callback "from time to time". 522will simply call the callback "from time to time".
520 523
521Example: read lines from STDIN, but only process them when the 524Example: read lines from STDIN, but only process them when the
522program is otherwise idle: 525program is otherwise idle:
1145 1148
1146# basically a tuned-down version of common::sense 1149# basically a tuned-down version of common::sense
1147sub common_sense { 1150sub common_sense {
1148 # from common:.sense 1.0 1151 # from common:.sense 1.0
1149 ${^WARNING_BITS} = "\xfc\x3f\x33\x00\x0f\xf3\xcf\xc0\xf3\xfc\x33\x00"; 1152 ${^WARNING_BITS} = "\xfc\x3f\x33\x00\x0f\xf3\xcf\xc0\xf3\xfc\x33\x00";
1150 # use strict vars subs 1153 # use strict vars subs - NO UTF-8, as Util.pm doesn't like this atm. (uts46data.pl)
1151 $^H |= 0x00000600; 1154 $^H |= 0x00000600;
1152} 1155}
1153 1156
1154BEGIN { AnyEvent::common_sense } 1157BEGIN { AnyEvent::common_sense }
1155 1158
1156use Carp (); 1159use Carp ();
1157 1160
1158our $VERSION = '5.22'; 1161our $VERSION = '5.24';
1159our $MODEL; 1162our $MODEL;
1160 1163
1161our $AUTOLOAD; 1164our $AUTOLOAD;
1162our @ISA; 1165our @ISA;
1163 1166
1164our @REGISTRY; 1167our @REGISTRY;
1165 1168
1166our $VERBOSE; 1169our $VERBOSE;
1167 1170
1168BEGIN { 1171BEGIN {
1172 eval "sub CYGWIN(){" . (($^O =~ /cygwin/i) *1) . "}";
1169 eval "sub WIN32(){ " . (($^O =~ /mswin32/i)*1) ." }"; 1173 eval "sub WIN32 (){" . (($^O =~ /mswin32/i)*1) . "}";
1170 eval "sub TAINT(){ " . (${^TAINT}*1) . " }"; 1174 eval "sub TAINT (){" . (${^TAINT} *1) . "}";
1171 1175
1172 delete @ENV{grep /^PERL_ANYEVENT_/, keys %ENV} 1176 delete @ENV{grep /^PERL_ANYEVENT_/, keys %ENV}
1173 if ${^TAINT}; 1177 if ${^TAINT};
1174 1178
1175 $VERBOSE = $ENV{PERL_ANYEVENT_VERBOSE}*1; 1179 $VERBOSE = $ENV{PERL_ANYEVENT_VERBOSE}*1;
1386 warn "AnyEvent: using Time::HiRes for sub-second timing accuracy.\n" if $VERBOSE >= 8; 1390 warn "AnyEvent: using Time::HiRes for sub-second timing accuracy.\n" if $VERBOSE >= 8;
1387 *_time = \&Time::HiRes::time; 1391 *_time = \&Time::HiRes::time;
1388 # if (eval "use POSIX (); (POSIX::times())... 1392 # if (eval "use POSIX (); (POSIX::times())...
1389 } else { 1393 } else {
1390 warn "AnyEvent: using built-in time(), WARNING, no sub-second resolution!\n" if $VERBOSE; 1394 warn "AnyEvent: using built-in time(), WARNING, no sub-second resolution!\n" if $VERBOSE;
1391 *_time = sub { time }; # epic fail 1395 *_time = sub (){ time }; # epic fail
1392 } 1396 }
1393 1397
1394 &_time 1398 &_time
1395} 1399}
1396 1400
2534 2538
2535 2539
2536=head1 FORK 2540=head1 FORK
2537 2541
2538Most event libraries are not fork-safe. The ones who are usually are 2542Most event libraries are not fork-safe. The ones who are usually are
2539because they rely on inefficient but fork-safe C<select> or C<poll> 2543because they rely on inefficient but fork-safe C<select> or C<poll> calls
2540calls. Only L<EV> is fully fork-aware. 2544- higher performance APIs such as BSD's kqueue or the dreaded Linux epoll
2545are usually badly thought-out hacks that are incompatible with fork in
2546one way or another. Only L<EV> is fully fork-aware and ensures that you
2547continue event-processing in both parent and child (or both, if you know
2548what you are doing).
2541 2549
2542This means that, in general, you cannot fork and do event processing 2550This means that, in general, you cannot fork and do event processing in
2543in the child if a watcher was created before the fork (which in turn 2551the child if the event library was initialised before the fork (which
2544initialises the event library). 2552usually happens when the first AnyEvent watcher is created, or the library
2553is loaded).
2545 2554
2546If you have to fork, you must either do so I<before> creating your first 2555If you have to fork, you must either do so I<before> creating your first
2547watcher OR you must not use AnyEvent at all in the child OR you must do 2556watcher OR you must not use AnyEvent at all in the child OR you must do
2548something completely out of the scope of AnyEvent. 2557something completely out of the scope of AnyEvent.
2549 2558
2550The problem of doing event processing in the parent I<and> the child 2559The problem of doing event processing in the parent I<and> the child
2551is much more complicated: even for backends that I<are> fork-aware or 2560is much more complicated: even for backends that I<are> fork-aware or
2552fork-safe, their behaviour is not usually what you want: fork clones all 2561fork-safe, their behaviour is not usually what you want: fork clones all
2553watchers, that means all timers, I/O watchers etc. are active in both 2562watchers, that means all timers, I/O watchers etc. are active in both
2554parent and child, which is almost never what you want. 2563parent and child, which is almost never what you want. USing C<exec>
2564to start worker children from some kind of manage rprocess is usually
2565preferred, because it is much easier and cleaner, at the expense of having
2566to have another binary.
2555 2567
2556 2568
2557=head1 SECURITY CONSIDERATIONS 2569=head1 SECURITY CONSIDERATIONS
2558 2570
2559AnyEvent can be forced to load any event model via 2571AnyEvent can be forced to load any event model via

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines