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

Comparing AnyEvent/README (file contents):
Revision 1.51 by root, Sun Aug 9 16:05:11 2009 UTC vs.
Revision 1.57 by root, Sat Dec 5 02:52:03 2009 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.
576 after => 1, 599 after => 1,
577 cb => sub { $result_ready->send }, 600 cb => sub { $result_ready->send },
578 ); 601 );
579 602
580 # this "blocks" (while handling events) till the callback 603 # this "blocks" (while handling events) till the callback
581 # calls -<send 604 # calls ->send
582 $result_ready->recv; 605 $result_ready->recv;
583 606
584 Example: wait for a timer, but take advantage of the fact that condition 607 Example: wait for a timer, but take advantage of the fact that condition
585 variables are also callable directly. 608 variables are also callable directly.
586 609
643 into one. For example, a function that pings many hosts in parallel 666 into one. For example, a function that pings many hosts in parallel
644 might want to use a condition variable for the whole process. 667 might want to use a condition variable for the whole process.
645 668
646 Every call to "->begin" will increment a counter, and every call to 669 Every call to "->begin" will increment a counter, and every call to
647 "->end" will decrement it. If the counter reaches 0 in "->end", the 670 "->end" will decrement it. If the counter reaches 0 in "->end", the
648 (last) callback passed to "begin" will be executed. That callback is 671 (last) callback passed to "begin" will be executed, passing the
649 *supposed* to call "->send", but that is not required. If no 672 condvar as first argument. That callback is *supposed* to call
673 "->send", but that is not required. If no group callback was set,
650 callback was set, "send" will be called without any arguments. 674 "send" will be called without any arguments.
651 675
652 You can think of "$cv->send" giving you an OR condition (one call 676 You can think of "$cv->send" giving you an OR condition (one call
653 sends), while "$cv->begin" and "$cv->end" giving you an AND 677 sends), while "$cv->begin" and "$cv->end" giving you an AND
654 condition (all "begin" calls must be "end"'ed before the condvar 678 condition (all "begin" calls must be "end"'ed before the condvar
655 sends). 679 sends).
683 that are begung can potentially be zero: 707 that are begung can potentially be zero:
684 708
685 my $cv = AnyEvent->condvar; 709 my $cv = AnyEvent->condvar;
686 710
687 my %result; 711 my %result;
688 $cv->begin (sub { $cv->send (\%result) }); 712 $cv->begin (sub { shift->send (\%result) });
689 713
690 for my $host (@list_of_hosts) { 714 for my $host (@list_of_hosts) {
691 $cv->begin; 715 $cv->begin;
692 ping_host_then_call_callback $host, sub { 716 ping_host_then_call_callback $host, sub {
693 $result{$host} = ...; 717 $result{$host} = ...;
1227 warn "read: $input\n"; # output what has been read 1251 warn "read: $input\n"; # output what has been read
1228 $cv->send if $input =~ /^q/i; # quit program if /^q/i 1252 $cv->send if $input =~ /^q/i; # quit program if /^q/i
1229 }, 1253 },
1230 ); 1254 );
1231 1255
1232 my $time_watcher; # can only be used once
1233
1234 sub new_timer {
1235 $timer = AnyEvent->timer (after => 1, cb => sub { 1256 my $time_watcher = AnyEvent->timer (after => 1, interval => 1, cb => sub {
1236 warn "timeout\n"; # print 'timeout' about every second 1257 warn "timeout\n"; # print 'timeout' at most every second
1237 &new_timer; # and restart the time
1238 });
1239 } 1258 });
1240
1241 new_timer; # create first timer
1242 1259
1243 $cv->recv; # wait until user enters /^q/i 1260 $cv->recv; # wait until user enters /^q/i
1244 1261
1245REAL-WORLD EXAMPLE 1262REAL-WORLD EXAMPLE
1246 Consider the Net::FCP module. It features (among others) the following 1263 Consider the Net::FCP module. It features (among others) the following
1664 As you can see, the AnyEvent + EV combination even beats the 1681 As you can see, the AnyEvent + EV combination even beats the
1665 hand-optimised "raw sockets benchmark", while AnyEvent + its pure perl 1682 hand-optimised "raw sockets benchmark", while AnyEvent + its pure perl
1666 backend easily beats IO::Lambda and POE. 1683 backend easily beats IO::Lambda and POE.
1667 1684
1668 And even the 100% non-blocking version written using the high-level (and 1685 And even the 100% non-blocking version written using the high-level (and
1669 slow :) AnyEvent::Handle abstraction beats both POE and IO::Lambda by a 1686 slow :) AnyEvent::Handle abstraction beats both POE and IO::Lambda
1670 large margin, even though it does all of DNS, tcp-connect and socket I/O 1687 higher level ("unoptimised") abstractions by a large margin, even though
1671 in a non-blocking way. 1688 it does all of DNS, tcp-connect and socket I/O in a non-blocking way.
1672 1689
1673 The two AnyEvent benchmarks programs can be found as eg/ae0.pl and 1690 The two AnyEvent benchmarks programs can be found as eg/ae0.pl and
1674 eg/ae2.pl in the AnyEvent distribution, the remaining benchmarks are 1691 eg/ae2.pl in the AnyEvent distribution, the remaining benchmarks are
1675 part of the IO::lambda distribution and were used without any changes. 1692 part of the IO::Lambda distribution and were used without any changes.
1676 1693
1677SIGNALS 1694SIGNALS
1678 AnyEvent currently installs handlers for these signals: 1695 AnyEvent currently installs handlers for these signals:
1679 1696
1680 SIGCHLD 1697 SIGCHLD
1707 it's built-in modules) are required to use it. 1724 it's built-in modules) are required to use it.
1708 1725
1709 That does not mean that AnyEvent won't take advantage of some additional 1726 That does not mean that AnyEvent won't take advantage of some additional
1710 modules if they are installed. 1727 modules if they are installed.
1711 1728
1712 This section epxlains which additional modules will be used, and how 1729 This section explains which additional modules will be used, and how
1713 they affect AnyEvent's operetion. 1730 they affect AnyEvent's operation.
1714 1731
1715 Async::Interrupt 1732 Async::Interrupt
1716 This slightly arcane module is used to implement fast signal 1733 This slightly arcane module is used to implement fast signal
1717 handling: To my knowledge, there is no way to do completely 1734 handling: To my knowledge, there is no way to do completely
1718 race-free and quick signal handling in pure perl. To ensure that 1735 race-free and quick signal handling in pure perl. To ensure that
1721 10 seconds, look for $AnyEvent::MAX_SIGNAL_LATENCY). 1738 10 seconds, look for $AnyEvent::MAX_SIGNAL_LATENCY).
1722 1739
1723 If this module is available, then it will be used to implement 1740 If this module is available, then it will be used to implement
1724 signal catching, which means that signals will not be delayed, and 1741 signal catching, which means that signals will not be delayed, and
1725 the event loop will not be interrupted regularly, which is more 1742 the event loop will not be interrupted regularly, which is more
1726 efficient (And good for battery life on laptops). 1743 efficient (and good for battery life on laptops).
1727 1744
1728 This affects not just the pure-perl event loop, but also other event 1745 This affects not just the pure-perl event loop, but also other event
1729 loops that have no signal handling on their own (e.g. Glib, Tk, Qt). 1746 loops that have no signal handling on their own (e.g. Glib, Tk, Qt).
1730 1747
1731 Some event loops (POE, Event, Event::Lib) offer signal watchers 1748 Some event loops (POE, Event, Event::Lib) offer signal watchers
1748 "AnyEvent::Util::guard". This speeds up guards considerably (and 1765 "AnyEvent::Util::guard". This speeds up guards considerably (and
1749 uses a lot less memory), but otherwise doesn't affect guard 1766 uses a lot less memory), but otherwise doesn't affect guard
1750 operation much. It is purely used for performance. 1767 operation much. It is purely used for performance.
1751 1768
1752 JSON and JSON::XS 1769 JSON and JSON::XS
1753 This module is required when you want to read or write JSON data via 1770 One of these modules is required when you want to read or write JSON
1754 AnyEvent::Handle. It is also written in pure-perl, but can take 1771 data via AnyEvent::Handle. It is also written in pure-perl, but can
1755 advantage of the ultra-high-speed JSON::XS module when it is 1772 take advantage of the ultra-high-speed JSON::XS module when it is
1756 installed. 1773 installed.
1757 1774
1758 In fact, AnyEvent::Handle will use JSON::XS by default if it is 1775 In fact, AnyEvent::Handle will use JSON::XS by default if it is
1759 installed. 1776 installed.
1760 1777
1773FORK 1790FORK
1774 Most event libraries are not fork-safe. The ones who are usually are 1791 Most event libraries are not fork-safe. The ones who are usually are
1775 because they rely on inefficient but fork-safe "select" or "poll" calls. 1792 because they rely on inefficient but fork-safe "select" or "poll" calls.
1776 Only EV is fully fork-aware. 1793 Only EV is fully fork-aware.
1777 1794
1795 This means that, in general, you cannot fork and do event processing in
1796 the child if a watcher was created before the fork (which in turn
1797 initialises the event library).
1798
1778 If you have to fork, you must either do so *before* creating your first 1799 If you have to fork, you must either do so *before* creating your first
1779 watcher OR you must not use AnyEvent at all in the child OR you must do 1800 watcher OR you must not use AnyEvent at all in the child OR you must do
1780 something completely out of the scope of AnyEvent. 1801 something completely out of the scope of AnyEvent.
1802
1803 The problem of doing event processing in the parent *and* the child is
1804 much more complicated: even for backends that *are* fork-aware or
1805 fork-safe, their behaviour is not usually what you want: fork clones all
1806 watchers, that means all timers, I/O watchers etc. are active in both
1807 parent and child, which is almost never what you want.
1781 1808
1782SECURITY CONSIDERATIONS 1809SECURITY CONSIDERATIONS
1783 AnyEvent can be forced to load any event model via 1810 AnyEvent can be forced to load any event model via
1784 $ENV{PERL_ANYEVENT_MODEL}. While this cannot (to my knowledge) be used 1811 $ENV{PERL_ANYEVENT_MODEL}. While this cannot (to my knowledge) be used
1785 to execute arbitrary code or directly gain access, it can easily be used 1812 to execute arbitrary code or directly gain access, it can easily be used

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines