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.218 by root, Wed Jun 24 10:03:42 2009 UTC vs.
Revision 1.221 by root, Fri Jun 26 06:33:17 2009 UTC

392 392
393There is a slight catch to child watchers, however: you usually start them 393There is a slight catch to child watchers, however: you usually start them
394I<after> the child process was created, and this means the process could 394I<after> the child process was created, and this means the process could
395have exited already (and no SIGCHLD will be sent anymore). 395have exited already (and no SIGCHLD will be sent anymore).
396 396
397Not all event models handle this correctly (POE doesn't), but even for 397Not all event models handle this correctly (neither POE nor IO::Async do,
398see their AnyEvent::Impl manpages for details), but even for event models
398event models that I<do> handle this correctly, they usually need to be 399that I<do> handle this correctly, they usually need to be loaded before
399loaded before the process exits (i.e. before you fork in the first place). 400the process exits (i.e. before you fork in the first place). AnyEvent's
401pure perl event loop handles all cases correctly regardless of when you
402start the watcher.
400 403
401This means you cannot create a child watcher as the very first thing in an 404This means you cannot create a child watcher as the very first
402AnyEvent program, you I<have> to create at least one watcher before you 405thing in an AnyEvent program, you I<have> to create at least one
403C<fork> the child (alternatively, you can call C<AnyEvent::detect>). 406watcher before you C<fork> the child (alternatively, you can call
407C<AnyEvent::detect>).
404 408
405Example: fork a process and wait for it 409Example: fork a process and wait for it
406 410
407 my $done = AnyEvent->condvar; 411 my $done = AnyEvent->condvar;
408 412
730 AnyEvent::Impl::Tk based on Tk, very bad choice. 734 AnyEvent::Impl::Tk based on Tk, very bad choice.
731 AnyEvent::Impl::Qt based on Qt, cannot be autoprobed (see its docs). 735 AnyEvent::Impl::Qt based on Qt, cannot be autoprobed (see its docs).
732 AnyEvent::Impl::EventLib based on Event::Lib, leaks memory and worse. 736 AnyEvent::Impl::EventLib based on Event::Lib, leaks memory and worse.
733 AnyEvent::Impl::POE based on POE, not generic enough for full support. 737 AnyEvent::Impl::POE based on POE, not generic enough for full support.
734 738
739 # warning, support for IO::Async is only partial, as it is too broken
740 # and limited toe ven support the AnyEvent API. See AnyEvent::Impl::Async.
741 AnyEvent::Impl::IOAsync based on IO::Async, cannot be autoprobed (see its docs).
742
735There is no support for WxWidgets, as WxWidgets has no support for 743There is no support for WxWidgets, as WxWidgets has no support for
736watching file handles. However, you can use WxWidgets through the 744watching file handles. However, you can use WxWidgets through the
737POE Adaptor, as POE has a Wx backend that simply polls 20 times per 745POE Adaptor, as POE has a Wx backend that simply polls 20 times per
738second, which was considered to be too horrible to even consider for 746second, which was considered to be too horrible to even consider for
739AnyEvent. Likewise, other POE backends can be used by AnyEvent by using 747AnyEvent. Likewise, other POE backends can be used by AnyEvent by using
931no warnings; 939no warnings;
932use strict qw(vars subs); 940use strict qw(vars subs);
933 941
934use Carp; 942use Carp;
935 943
936our $VERSION = 4.412; 944our $VERSION = 4.42;
937our $MODEL; 945our $MODEL;
938 946
939our $AUTOLOAD; 947our $AUTOLOAD;
940our @ISA; 948our @ISA;
941 949
974 [Event::Lib:: => AnyEvent::Impl::EventLib::], # too buggy 982 [Event::Lib:: => AnyEvent::Impl::EventLib::], # too buggy
975 [Qt:: => AnyEvent::Impl::Qt::], # requires special main program 983 [Qt:: => AnyEvent::Impl::Qt::], # requires special main program
976 [POE::Kernel:: => AnyEvent::Impl::POE::], # lasciate ogni speranza 984 [POE::Kernel:: => AnyEvent::Impl::POE::], # lasciate ogni speranza
977 [Wx:: => AnyEvent::Impl::POE::], 985 [Wx:: => AnyEvent::Impl::POE::],
978 [Prima:: => AnyEvent::Impl::POE::], 986 [Prima:: => AnyEvent::Impl::POE::],
987 # IO::Async is just too broken - we would need workaorunds for its
988 # byzantine signal and broken child handling, among others.
989 # IO::Async is rather hard to detect, as it doesn't have any
990 # obvious default class.
991# [IO::Async:: => AnyEvent::Impl::IOAsync::], # requires special main program
992# [IO::Async::Loop:: => AnyEvent::Impl::IOAsync::], # requires special main program
993# [IO::Async::Notifier:: => AnyEvent::Impl::IOAsync::], # requires special main program
979); 994);
980 995
981our %method = map +($_ => 1), 996our %method = map +($_ => 1),
982 qw(io timer time now now_update signal child idle condvar one_event DESTROY); 997 qw(io timer time now now_update signal child idle condvar one_event DESTROY);
983 998
1075} 1090}
1076 1091
1077# utility function to dup a filehandle. this is used by many backends 1092# utility function to dup a filehandle. this is used by many backends
1078# to support binding more than one watcher per filehandle (they usually 1093# to support binding more than one watcher per filehandle (they usually
1079# allow only one watcher per fd, so we dup it to get a different one). 1094# allow only one watcher per fd, so we dup it to get a different one).
1080sub _dupfh($$$$) { 1095sub _dupfh($$;$$) {
1081 my ($poll, $fh, $r, $w) = @_; 1096 my ($poll, $fh, $r, $w) = @_;
1082 1097
1083 # cygwin requires the fh mode to be matching, unix doesn't 1098 # cygwin requires the fh mode to be matching, unix doesn't
1084 my ($rw, $mode) = $poll eq "r" ? ($r, "<") 1099 my ($rw, $mode) = $poll eq "r" ? ($r, "<")
1085 : $poll eq "w" ? ($w, ">") 1100 : $poll eq "w" ? ($w, ">")
1680 EV/Any 100000 224 2.88 0.34 0.27 EV + AnyEvent watchers 1695 EV/Any 100000 224 2.88 0.34 0.27 EV + AnyEvent watchers
1681 CoroEV/Any 100000 224 2.85 0.35 0.28 coroutines + Coro::Signal 1696 CoroEV/Any 100000 224 2.85 0.35 0.28 coroutines + Coro::Signal
1682 Perl/Any 100000 452 4.13 0.73 0.95 pure perl implementation 1697 Perl/Any 100000 452 4.13 0.73 0.95 pure perl implementation
1683 Event/Event 16000 517 32.20 31.80 0.81 Event native interface 1698 Event/Event 16000 517 32.20 31.80 0.81 Event native interface
1684 Event/Any 16000 590 35.85 31.55 1.06 Event + AnyEvent watchers 1699 Event/Any 16000 590 35.85 31.55 1.06 Event + AnyEvent watchers
1700 IOAsync/Any 16000 989 38.10 32.77 11.13 via IO::Async::Loop::IO_Poll
1701 IOAsync/Any 16000 990 37.59 29.50 10.61 via IO::Async::Loop::Epoll
1685 Glib/Any 16000 1357 102.33 12.31 51.00 quadratic behaviour 1702 Glib/Any 16000 1357 102.33 12.31 51.00 quadratic behaviour
1686 Tk/Any 2000 1860 27.20 66.31 14.00 SEGV with >> 2000 watchers 1703 Tk/Any 2000 1860 27.20 66.31 14.00 SEGV with >> 2000 watchers
1687 POE/Event 2000 6328 109.99 751.67 14.02 via POE::Loop::Event 1704 POE/Event 2000 6328 109.99 751.67 14.02 via POE::Loop::Event
1688 POE/Select 2000 6027 94.54 809.13 579.80 via POE::Loop::Select 1705 POE/Select 2000 6027 94.54 809.13 579.80 via POE::Loop::Select
1689 1706
1718performance becomes really bad with lots of file descriptors (and few of 1735performance becomes really bad with lots of file descriptors (and few of
1719them active), of course, but this was not subject of this benchmark. 1736them active), of course, but this was not subject of this benchmark.
1720 1737
1721The C<Event> module has a relatively high setup and callback invocation 1738The C<Event> module has a relatively high setup and callback invocation
1722cost, but overall scores in on the third place. 1739cost, but overall scores in on the third place.
1740
1741C<IO::Async> performs admirably well, about on par with C<Event>, even
1742when using its pure perl backend.
1723 1743
1724C<Glib>'s memory usage is quite a bit higher, but it features a 1744C<Glib>'s memory usage is quite a bit higher, but it features a
1725faster callback invocation and overall ends up in the same class as 1745faster callback invocation and overall ends up in the same class as
1726C<Event>. However, Glib scales extremely badly, doubling the number of 1746C<Event>. However, Glib scales extremely badly, doubling the number of
1727watchers increases the processing time by more than a factor of four, 1747watchers increases the processing time by more than a factor of four,
1805it to another server. This includes deleting the old timeout and creating 1825it to another server. This includes deleting the old timeout and creating
1806a new one that moves the timeout into the future. 1826a new one that moves the timeout into the future.
1807 1827
1808=head3 Results 1828=head3 Results
1809 1829
1810 name sockets create request 1830 name sockets create request
1811 EV 20000 69.01 11.16 1831 EV 20000 69.01 11.16
1812 Perl 20000 73.32 35.87 1832 Perl 20000 73.32 35.87
1833 IOAsync 20000 157.00 98.14 epoll
1834 IOAsync 20000 159.31 616.06 poll
1813 Event 20000 212.62 257.32 1835 Event 20000 212.62 257.32
1814 Glib 20000 651.16 1896.30 1836 Glib 20000 651.16 1896.30
1815 POE 20000 349.67 12317.24 uses POE::Loop::Event 1837 POE 20000 349.67 12317.24 uses POE::Loop::Event
1816 1838
1817=head3 Discussion 1839=head3 Discussion
1818 1840
1819This benchmark I<does> measure scalability and overall performance of the 1841This benchmark I<does> measure scalability and overall performance of the
1820particular event loop. 1842particular event loop.
1822EV is again fastest. Since it is using epoll on my system, the setup time 1844EV is again fastest. Since it is using epoll on my system, the setup time
1823is relatively high, though. 1845is relatively high, though.
1824 1846
1825Perl surprisingly comes second. It is much faster than the C-based event 1847Perl surprisingly comes second. It is much faster than the C-based event
1826loops Event and Glib. 1848loops Event and Glib.
1849
1850IO::Async performs very well when using its epoll backend, and still quite
1851good compared to Glib when using its pure perl backend.
1827 1852
1828Event suffers from high setup time as well (look at its code and you will 1853Event suffers from high setup time as well (look at its code and you will
1829understand why). Callback invocation also has a high overhead compared to 1854understand why). Callback invocation also has a high overhead compared to
1830the C<< $_->() for .. >>-style loop that the Perl event loop uses. Event 1855the C<< $_->() for .. >>-style loop that the Perl event loop uses. Event
1831uses select or poll in basically all documented configurations. 1856uses select or poll in basically all documented configurations.
1964 1989
1965A handler for C<SIGCHLD> is installed by AnyEvent's child watcher 1990A handler for C<SIGCHLD> is installed by AnyEvent's child watcher
1966emulation for event loops that do not support them natively. Also, some 1991emulation for event loops that do not support them natively. Also, some
1967event loops install a similar handler. 1992event loops install a similar handler.
1968 1993
1994If, when AnyEvent is loaded, SIGCHLD is set to IGNORE, then AnyEvent will
1995reset it to default, to avoid losing child exit statuses.
1996
1969=item SIGPIPE 1997=item SIGPIPE
1970 1998
1971A no-op handler is installed for C<SIGPIPE> when C<$SIG{PIPE}> is C<undef> 1999A no-op handler is installed for C<SIGPIPE> when C<$SIG{PIPE}> is C<undef>
1972when AnyEvent gets loaded. 2000when AnyEvent gets loaded.
1973 2001
1984 2012
1985=back 2013=back
1986 2014
1987=cut 2015=cut
1988 2016
2017undef $SIG{CHLD}
2018 if $SIG{CHLD} eq 'IGNORE';
2019
1989$SIG{PIPE} = sub { } 2020$SIG{PIPE} = sub { }
1990 unless defined $SIG{PIPE}; 2021 unless defined $SIG{PIPE};
1991
1992 2022
1993=head1 FORK 2023=head1 FORK
1994 2024
1995Most event libraries are not fork-safe. The ones who are usually are 2025Most event libraries are not fork-safe. The ones who are usually are
1996because they rely on inefficient but fork-safe C<select> or C<poll> 2026because they rely on inefficient but fork-safe C<select> or C<poll>

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines