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

Comparing AnyEvent/README (file contents):
Revision 1.53 by root, Fri Aug 21 11:59:24 2009 UTC vs.
Revision 1.59 by root, Tue Jan 5 10:45:25 2010 UTC

354 time, which might affect timers and time-outs. 354 time, which might affect timers and time-outs.
355 355
356 When this is the case, you can call this method, which will update 356 When this is the case, you can call this method, which will update
357 the event loop's idea of "current time". 357 the event loop's idea of "current time".
358 358
359 A typical example would be a script in a web server (e.g.
360 "mod_perl") - when mod_perl executes the script, then the event loop
361 will have the wrong idea about the "current time" (being potentially
362 far in the past, when the script ran the last time). In that case
363 you should arrange a call to "AnyEvent->now_update" each time the
364 web server process wakes up again (e.g. at the start of your script,
365 or in a handler).
366
359 Note that updating the time *might* cause some events to be handled. 367 Note that updating the time *might* cause some events to be handled.
360 368
361 SIGNAL WATCHERS 369 SIGNAL WATCHERS
362 $w = AnyEvent->signal (signal => <uppercase_signal_name>, cb => <callback>); 370 $w = AnyEvent->signal (signal => <uppercase_signal_name>, cb => <callback>);
363 371
383 correctly. 391 correctly.
384 392
385 Example: exit on SIGINT 393 Example: exit on SIGINT
386 394
387 my $w = AnyEvent->signal (signal => "INT", cb => sub { exit 1 }); 395 my $w = AnyEvent->signal (signal => "INT", cb => sub { exit 1 });
396
397 Restart Behaviour
398 While restart behaviour is up to the event loop implementation, most
399 will not restart syscalls (that includes Async::Interrupt and AnyEvent's
400 pure perl implementation).
401
402 Safe/Unsafe Signals
403 Perl signals can be either "safe" (synchronous to opcode handling) or
404 "unsafe" (asynchronous) - the former might get delayed indefinitely, the
405 latter might corrupt your memory.
406
407 AnyEvent signal handlers are, in addition, synchronous to the event
408 loop, i.e. they will not interrupt your running perl program but will
409 only be called as part of the normal event handling (just like timer,
410 I/O etc. callbacks, too).
388 411
389 Signal Races, Delays and Workarounds 412 Signal Races, Delays and Workarounds
390 Many event loops (e.g. Glib, Tk, Qt, IO::Async) do not support attaching 413 Many event loops (e.g. Glib, Tk, Qt, IO::Async) do not support attaching
391 callbacks to signals in a generic way, which is a pity, as you cannot do 414 callbacks to signals in a generic way, which is a pity, as you cannot do
392 race-free signal handling in perl, requiring C libraries for this. 415 race-free signal handling in perl, requiring C libraries for this.
463 $done->recv; 486 $done->recv;
464 487
465 IDLE WATCHERS 488 IDLE WATCHERS
466 $w = AnyEvent->idle (cb => <callback>); 489 $w = AnyEvent->idle (cb => <callback>);
467 490
468 Sometimes there is a need to do something, but it is not so important to 491 Repeatedly invoke the callback after the process becomes idle, until
469 do it instantly, but only when there is nothing better to do. This 492 either the watcher is destroyed or new events have been detected.
470 "nothing better to do" is usually defined to be "no other events need
471 attention by the event loop".
472 493
473 Idle watchers ideally get invoked when the event loop has nothing better 494 Idle watchers are useful when there is a need to do something, but it is
474 to do, just before it would block the process to wait for new events. 495 not so important (or wise) to do it instantly. The callback will be
475 Instead of blocking, the idle watcher is invoked. 496 invoked only when there is "nothing better to do", which is usually
497 defined as "all outstanding events have been handled and no new events
498 have been detected". That means that idle watchers ideally get invoked
499 when the event loop has just polled for new events but none have been
500 detected. Instead of blocking to wait for more events, the idle watchers
501 will be invoked.
476 502
477 Most event loops unfortunately do not really support idle watchers (only 503 Unfortunately, most event loops do not really support idle watchers
478 EV, Event and Glib do it in a usable fashion) - for the rest, AnyEvent 504 (only EV, Event and Glib do it in a usable fashion) - for the rest,
479 will simply call the callback "from time to time". 505 AnyEvent will simply call the callback "from time to time".
480 506
481 Example: read lines from STDIN, but only process them when the program 507 Example: read lines from STDIN, but only process them when the program
482 is otherwise idle: 508 is otherwise idle:
483 509
484 my @lines; # read data 510 my @lines; # read data
896 You should check $AnyEvent::MODEL before adding to this array, 922 You should check $AnyEvent::MODEL before adding to this array,
897 though: if it is defined then the event loop has already been 923 though: if it is defined then the event loop has already been
898 detected, and the array will be ignored. 924 detected, and the array will be ignored.
899 925
900 Best use "AnyEvent::post_detect { BLOCK }" when your application 926 Best use "AnyEvent::post_detect { BLOCK }" when your application
901 allows it,as it takes care of these details. 927 allows it, as it takes care of these details.
902 928
903 This variable is mainly useful for modules that can do something 929 This variable is mainly useful for modules that can do something
904 useful when AnyEvent is used and thus want to know when it is 930 useful when AnyEvent is used and thus want to know when it is
905 initialised, but do not need to even load it by default. This array 931 initialised, but do not need to even load it by default. This array
906 provides the means to hook into AnyEvent passively, without loading 932 provides the means to hook into AnyEvent passively, without loading
907 it. 933 it.
934
935 Example: To load Coro::AnyEvent whenever Coro and AnyEvent are used
936 together, you could put this into Coro (this is the actual code used
937 by Coro to accomplish this):
938
939 if (defined $AnyEvent::MODEL) {
940 # AnyEvent already initialised, so load Coro::AnyEvent
941 require Coro::AnyEvent;
942 } else {
943 # AnyEvent not yet initialised, so make sure to load Coro::AnyEvent
944 # as soon as it is
945 push @AnyEvent::post_detect, sub { require Coro::AnyEvent };
946 }
908 947
909WHAT TO DO IN A MODULE 948WHAT TO DO IN A MODULE
910 As a module author, you should "use AnyEvent" and call AnyEvent methods 949 As a module author, you should "use AnyEvent" and call AnyEvent methods
911 freely, but you should not load a specific event module or rely on it. 950 freely, but you should not load a specific event module or rely on it.
912 951
1228 warn "read: $input\n"; # output what has been read 1267 warn "read: $input\n"; # output what has been read
1229 $cv->send if $input =~ /^q/i; # quit program if /^q/i 1268 $cv->send if $input =~ /^q/i; # quit program if /^q/i
1230 }, 1269 },
1231 ); 1270 );
1232 1271
1233 my $time_watcher; # can only be used once
1234
1235 sub new_timer {
1236 $timer = AnyEvent->timer (after => 1, cb => sub { 1272 my $time_watcher = AnyEvent->timer (after => 1, interval => 1, cb => sub {
1237 warn "timeout\n"; # print 'timeout' about every second 1273 warn "timeout\n"; # print 'timeout' at most every second
1238 &new_timer; # and restart the time
1239 });
1240 } 1274 });
1241
1242 new_timer; # create first timer
1243 1275
1244 $cv->recv; # wait until user enters /^q/i 1276 $cv->recv; # wait until user enters /^q/i
1245 1277
1246REAL-WORLD EXAMPLE 1278REAL-WORLD EXAMPLE
1247 Consider the Net::FCP module. It features (among others) the following 1279 Consider the Net::FCP module. It features (among others) the following
1665 As you can see, the AnyEvent + EV combination even beats the 1697 As you can see, the AnyEvent + EV combination even beats the
1666 hand-optimised "raw sockets benchmark", while AnyEvent + its pure perl 1698 hand-optimised "raw sockets benchmark", while AnyEvent + its pure perl
1667 backend easily beats IO::Lambda and POE. 1699 backend easily beats IO::Lambda and POE.
1668 1700
1669 And even the 100% non-blocking version written using the high-level (and 1701 And even the 100% non-blocking version written using the high-level (and
1670 slow :) AnyEvent::Handle abstraction beats both POE and IO::Lambda by a 1702 slow :) AnyEvent::Handle abstraction beats both POE and IO::Lambda
1671 large margin, even though it does all of DNS, tcp-connect and socket I/O 1703 higher level ("unoptimised") abstractions by a large margin, even though
1672 in a non-blocking way. 1704 it does all of DNS, tcp-connect and socket I/O in a non-blocking way.
1673 1705
1674 The two AnyEvent benchmarks programs can be found as eg/ae0.pl and 1706 The two AnyEvent benchmarks programs can be found as eg/ae0.pl and
1675 eg/ae2.pl in the AnyEvent distribution, the remaining benchmarks are 1707 eg/ae2.pl in the AnyEvent distribution, the remaining benchmarks are
1676 part of the IO::lambda distribution and were used without any changes. 1708 part of the IO::Lambda distribution and were used without any changes.
1677 1709
1678SIGNALS 1710SIGNALS
1679 AnyEvent currently installs handlers for these signals: 1711 AnyEvent currently installs handlers for these signals:
1680 1712
1681 SIGCHLD 1713 SIGCHLD
1708 it's built-in modules) are required to use it. 1740 it's built-in modules) are required to use it.
1709 1741
1710 That does not mean that AnyEvent won't take advantage of some additional 1742 That does not mean that AnyEvent won't take advantage of some additional
1711 modules if they are installed. 1743 modules if they are installed.
1712 1744
1713 This section epxlains which additional modules will be used, and how 1745 This section explains which additional modules will be used, and how
1714 they affect AnyEvent's operetion. 1746 they affect AnyEvent's operation.
1715 1747
1716 Async::Interrupt 1748 Async::Interrupt
1717 This slightly arcane module is used to implement fast signal 1749 This slightly arcane module is used to implement fast signal
1718 handling: To my knowledge, there is no way to do completely 1750 handling: To my knowledge, there is no way to do completely
1719 race-free and quick signal handling in pure perl. To ensure that 1751 race-free and quick signal handling in pure perl. To ensure that
1722 10 seconds, look for $AnyEvent::MAX_SIGNAL_LATENCY). 1754 10 seconds, look for $AnyEvent::MAX_SIGNAL_LATENCY).
1723 1755
1724 If this module is available, then it will be used to implement 1756 If this module is available, then it will be used to implement
1725 signal catching, which means that signals will not be delayed, and 1757 signal catching, which means that signals will not be delayed, and
1726 the event loop will not be interrupted regularly, which is more 1758 the event loop will not be interrupted regularly, which is more
1727 efficient (And good for battery life on laptops). 1759 efficient (and good for battery life on laptops).
1728 1760
1729 This affects not just the pure-perl event loop, but also other event 1761 This affects not just the pure-perl event loop, but also other event
1730 loops that have no signal handling on their own (e.g. Glib, Tk, Qt). 1762 loops that have no signal handling on their own (e.g. Glib, Tk, Qt).
1731 1763
1732 Some event loops (POE, Event, Event::Lib) offer signal watchers 1764 Some event loops (POE, Event, Event::Lib) offer signal watchers
1749 "AnyEvent::Util::guard". This speeds up guards considerably (and 1781 "AnyEvent::Util::guard". This speeds up guards considerably (and
1750 uses a lot less memory), but otherwise doesn't affect guard 1782 uses a lot less memory), but otherwise doesn't affect guard
1751 operation much. It is purely used for performance. 1783 operation much. It is purely used for performance.
1752 1784
1753 JSON and JSON::XS 1785 JSON and JSON::XS
1754 This module is required when you want to read or write JSON data via 1786 One of these modules is required when you want to read or write JSON
1755 AnyEvent::Handle. It is also written in pure-perl, but can take 1787 data via AnyEvent::Handle. It is also written in pure-perl, but can
1756 advantage of the ultra-high-speed JSON::XS module when it is 1788 take advantage of the ultra-high-speed JSON::XS module when it is
1757 installed. 1789 installed.
1758 1790
1759 In fact, AnyEvent::Handle will use JSON::XS by default if it is 1791 In fact, AnyEvent::Handle will use JSON::XS by default if it is
1760 installed. 1792 installed.
1761 1793
1771 additionally use it to try to use a monotonic clock for timing 1803 additionally use it to try to use a monotonic clock for timing
1772 stability. 1804 stability.
1773 1805
1774FORK 1806FORK
1775 Most event libraries are not fork-safe. The ones who are usually are 1807 Most event libraries are not fork-safe. The ones who are usually are
1776 because they rely on inefficient but fork-safe "select" or "poll" calls. 1808 because they rely on inefficient but fork-safe "select" or "poll" calls
1777 Only EV is fully fork-aware. 1809 - higher performance APIs such as BSD's kqueue or the dreaded Linux
1810 epoll are usually badly thought-out hacks that are incompatible with
1811 fork in one way or another. Only EV is fully fork-aware and ensures that
1812 you continue event-processing in both parent and child (or both, if you
1813 know what you are doing).
1814
1815 This means that, in general, you cannot fork and do event processing in
1816 the child if the event library was initialised before the fork (which
1817 usually happens when the first AnyEvent watcher is created, or the
1818 library is loaded).
1778 1819
1779 If you have to fork, you must either do so *before* creating your first 1820 If you have to fork, you must either do so *before* creating your first
1780 watcher OR you must not use AnyEvent at all in the child OR you must do 1821 watcher OR you must not use AnyEvent at all in the child OR you must do
1781 something completely out of the scope of AnyEvent. 1822 something completely out of the scope of AnyEvent.
1823
1824 The problem of doing event processing in the parent *and* the child is
1825 much more complicated: even for backends that *are* fork-aware or
1826 fork-safe, their behaviour is not usually what you want: fork clones all
1827 watchers, that means all timers, I/O watchers etc. are active in both
1828 parent and child, which is almost never what you want. USing "exec" to
1829 start worker children from some kind of manage rprocess is usually
1830 preferred, because it is much easier and cleaner, at the expense of
1831 having to have another binary.
1782 1832
1783SECURITY CONSIDERATIONS 1833SECURITY CONSIDERATIONS
1784 AnyEvent can be forced to load any event model via 1834 AnyEvent can be forced to load any event model via
1785 $ENV{PERL_ANYEVENT_MODEL}. While this cannot (to my knowledge) be used 1835 $ENV{PERL_ANYEVENT_MODEL}. While this cannot (to my knowledge) be used
1786 to execute arbitrary code or directly gain access, it can easily be used 1836 to execute arbitrary code or directly gain access, it can easily be used

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines