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.61 by root, Fri Apr 25 01:55:25 2008 UTC vs.
Revision 1.78 by root, Fri Apr 25 09:06:27 2008 UTC

136 136
137Note that C<my $w; $w => combination. This is necessary because in Perl, 137Note that C<my $w; $w => combination. This is necessary because in Perl,
138my variables are only visible after the statement in which they are 138my variables are only visible after the statement in which they are
139declared. 139declared.
140 140
141=head2 IO WATCHERS 141=head2 I/O WATCHERS
142 142
143You can create an I/O watcher by calling the C<< AnyEvent->io >> method 143You can create an I/O watcher by calling the C<< AnyEvent->io >> method
144with the following mandatory key-value pairs as arguments: 144with the following mandatory key-value pairs as arguments:
145 145
146C<fh> the Perl I<file handle> (I<not> file descriptor) to watch for 146C<fh> the Perl I<file handle> (I<not> file descriptor) to watch for
369 369
370There is no support for WxWidgets, as WxWidgets has no support for 370There is no support for WxWidgets, as WxWidgets has no support for
371watching file handles. However, you can use WxWidgets through the 371watching file handles. However, you can use WxWidgets through the
372POE Adaptor, as POE has a Wx backend that simply polls 20 times per 372POE Adaptor, as POE has a Wx backend that simply polls 20 times per
373second, which was considered to be too horrible to even consider for 373second, which was considered to be too horrible to even consider for
374AnyEvent. Likewise, other POE backends can be used by Anyevent by using 374AnyEvent. Likewise, other POE backends can be used by AnyEvent by using
375it's adaptor. 375it's adaptor.
376
377AnyEvent knows about L<Prima> and L<Wx> and will try to use L<POE> when
378autodetecting them.
376 379
377=item AnyEvent::detect 380=item AnyEvent::detect
378 381
379Returns C<$AnyEvent::MODEL>, forcing autodetection of the event model 382Returns C<$AnyEvent::MODEL>, forcing autodetection of the event model
380if necessary. You should only call this function right before you would 383if necessary. You should only call this function right before you would
431no warnings; 434no warnings;
432use strict; 435use strict;
433 436
434use Carp; 437use Carp;
435 438
436our $VERSION = '3.2'; 439our $VERSION = '3.3';
437our $MODEL; 440our $MODEL;
438 441
439our $AUTOLOAD; 442our $AUTOLOAD;
440our @ISA; 443our @ISA;
441 444
448 [Coro::Event:: => AnyEvent::Impl::CoroEvent::], 451 [Coro::Event:: => AnyEvent::Impl::CoroEvent::],
449 [EV:: => AnyEvent::Impl::EV::], 452 [EV:: => AnyEvent::Impl::EV::],
450 [Event:: => AnyEvent::Impl::Event::], 453 [Event:: => AnyEvent::Impl::Event::],
451 [Glib:: => AnyEvent::Impl::Glib::], 454 [Glib:: => AnyEvent::Impl::Glib::],
452 [Tk:: => AnyEvent::Impl::Tk::], 455 [Tk:: => AnyEvent::Impl::Tk::],
456 [Wx:: => AnyEvent::Impl::POE::],
457 [Prima:: => AnyEvent::Impl::POE::],
453 [AnyEvent::Impl::Perl:: => AnyEvent::Impl::Perl::], 458 [AnyEvent::Impl::Perl:: => AnyEvent::Impl::Perl::],
454 # everything below here will not be autoprobed as the pureperl backend should work everywhere 459 # everything below here will not be autoprobed as the pureperl backend should work everywhere
455 [Event::Lib:: => AnyEvent::Impl::EventLib::], # too buggy 460 [Event::Lib:: => AnyEvent::Impl::EventLib::], # too buggy
456 [Qt:: => AnyEvent::Impl::Qt::], # requires special main program 461 [Qt:: => AnyEvent::Impl::Qt::], # requires special main program
457 [POE::Kernel:: => AnyEvent::Impl::POE::], # lasciate ogni speranza 462 [POE::Kernel:: => AnyEvent::Impl::POE::], # lasciate ogni speranza
701 706
702=back 707=back
703 708
704=head1 EXAMPLE PROGRAM 709=head1 EXAMPLE PROGRAM
705 710
706The following program uses an IO watcher to read data from STDIN, a timer 711The following program uses an I/O watcher to read data from STDIN, a timer
707to display a message once per second, and a condition variable to quit the 712to display a message once per second, and a condition variable to quit the
708program when the user enters quit: 713program when the user enters quit:
709 714
710 use AnyEvent; 715 use AnyEvent;
711 716
855 $quit->broadcast; 860 $quit->broadcast;
856 }); 861 });
857 862
858 $quit->wait; 863 $quit->wait;
859 864
865
866=head1 BENCHMARK
867
868To give you an idea of the performance and overheads that AnyEvent adds
869over the event loops themselves (and to give you an impression of the
870speed of various event loops), here is a benchmark of various supported
871event models natively and with anyevent. The benchmark creates a lot of
872timers (with a zero timeout) and I/O watchers (watching STDOUT, a pty, to
873become writable, which it is), lets them fire exactly once and destroys
874them again.
875
876Rewriting the benchmark to use many different sockets instead of using
877the same filehandle for all I/O watchers results in a much longer runtime
878(socket creation is expensive), but qualitatively the same figures, so it
879was not used.
880
881=head2 Explanation of the columns
882
883I<watcher> is the number of event watchers created/destroyed. Since
884different event models feature vastly different performances, each event
885loop was given a number of watchers so that overall runtime is acceptable
886and similar between tested event loop (and keep them from crashing): Glib
887would probably take thousands of years if asked to process the same number
888of watchers as EV in this benchmark.
889
890I<bytes> is the number of bytes (as measured by the resident set size,
891RSS) consumed by each watcher. This method of measuring captures both C
892and Perl-based overheads.
893
894I<create> is the time, in microseconds (millionths of seconds), that it
895takes to create a single watcher. The callback is a closure shared between
896all watchers, to avoid adding memory overhead. That means closure creation
897and memory usage is not included in the figures.
898
899I<invoke> is the time, in microseconds, used to invoke a simple
900callback. The callback simply counts down a Perl variable and after it was
901invoked "watcher" times, it would C<< ->broadcast >> a condvar once to
902signal the end of this phase.
903
904I<destroy> is the time, in microseconds, that it takes to destroy a single
905watcher.
906
907=head2 Results
908
909 name watchers bytes create invoke destroy comment
910 EV/EV 400000 244 0.56 0.46 0.31 EV native interface
911 EV/Any 100000 610 3.52 0.91 0.75 EV + AnyEvent watchers
912 CoroEV/Any 100000 610 3.49 0.92 0.75 coroutines + Coro::Signal
913 Perl/Any 100000 513 4.91 0.92 1.15 pure perl implementation
914 Event/Event 16000 523 28.05 21.38 0.86 Event native interface
915 Event/Any 16000 943 34.43 20.48 1.39 Event + AnyEvent watchers
916 Glib/Any 16000 1357 96.99 12.55 55.51 quadratic behaviour
917 Tk/Any 2000 1855 27.01 66.61 14.03 SEGV with >> 2000 watchers
918 POE/Event 2000 6644 108.15 768.19 14.33 via POE::Loop::Event
919 POE/Select 2000 6343 94.69 807.65 562.69 via POE::Loop::Select
920
921=head2 Discussion
922
923The benchmark does I<not> measure scalability of the event loop very
924well. For example, a select-based event loop (such as the pure perl one)
925can never compete with an event loop that uses epoll when the number of
926file descriptors grows high. In this benchmark, only a single filehandle
927is used (although some of the AnyEvent adaptors dup() its file descriptor
928to worka round bugs).
929
930C<EV> is the sole leader regarding speed and memory use, which are both
931maximal/minimal, respectively. Even when going through AnyEvent, there are
932only two event loops that use slightly less memory (the C<Event> module
933natively and the pure perl backend), and no faster event models, not even
934C<Event> natively.
935
936The pure perl implementation is hit in a few sweet spots (both the
937zero timeout and the use of a single fd hit optimisations in the perl
938interpreter and the backend itself, and all watchers become ready at the
939same time). Nevertheless this shows that it adds very little overhead in
940itself. Like any select-based backend its performance becomes really bad
941with lots of file descriptors (and few of them active), of course, but
942this was not subject of this benchmark.
943
944The C<Event> module has a relatively high setup and callback invocation cost,
945but overall scores on the third place.
946
947C<Glib>'s memory usage is quite a bit bit higher, but it features a
948faster callback invocation and overall ends up in the same class as
949C<Event>. However, Glib scales extremely badly, doubling the number of
950watchers increases the processing time by more than a factor of four,
951making it completely unusable when using larger numbers of watchers
952(note that only a single file descriptor was used in the benchmark, so
953inefficiencies of C<poll> do not account for this).
954
955The C<Tk> adaptor works relatively well. The fact that it crashes with
956more than 2000 watchers is a big setback, however, as correctness takes
957precedence over speed. Nevertheless, its performance is surprising, as the
958file descriptor is dup()ed for each watcher. This shows that the dup()
959employed by some adaptors is not a big performance issue (it does incur a
960hidden memory cost inside the kernel, though, that is not reflected in the
961figures above).
962
963C<POE>, regardless of underlying event loop (wether using its pure perl
964select-based backend or the Event module) shows abysmal performance and
965memory usage: Watchers use almost 30 times as much memory as EV watchers,
966and 10 times as much memory as both Event or EV via AnyEvent. Watcher
967invocation is almost 700 times slower than with AnyEvent's pure perl
968implementation. The design of the POE adaptor class in AnyEvent can not
969really account for this, as session creation overhead is small compared
970to execution of the state machine, which is coded pretty optimally within
971L<AnyEvent::Impl::POE>. POE simply seems to be abysmally slow.
972
973=head2 Summary
974
975Using EV through AnyEvent is faster than any other event loop, but most
976event loops have acceptable performance with or without AnyEvent.
977
978The overhead AnyEvent adds is usually much smaller than the overhead of
979the actual event loop, only with extremely fast event loops such as the EV
980adds AnyEvent significant overhead.
981
982And you should simply avoid POE like the plague if you want performance or
983reasonable memory usage.
984
985
860=head1 FORK 986=head1 FORK
861 987
862Most event libraries are not fork-safe. The ones who are usually are 988Most event libraries are not fork-safe. The ones who are usually are
863because they are so inefficient. Only L<EV> is fully fork-aware. 989because they are so inefficient. Only L<EV> is fully fork-aware.
864 990
865If you have to fork, you must either do so I<before> creating your first 991If you have to fork, you must either do so I<before> creating your first
866watcher OR you must not use AnyEvent at all in the child. 992watcher OR you must not use AnyEvent at all in the child.
993
867 994
868=head1 SECURITY CONSIDERATIONS 995=head1 SECURITY CONSIDERATIONS
869 996
870AnyEvent can be forced to load any event model via 997AnyEvent can be forced to load any event model via
871$ENV{PERL_ANYEVENT_MODEL}. While this cannot (to my knowledge) be used to 998$ENV{PERL_ANYEVENT_MODEL}. While this cannot (to my knowledge) be used to
879 1006
880 BEGIN { delete $ENV{PERL_ANYEVENT_MODEL} } 1007 BEGIN { delete $ENV{PERL_ANYEVENT_MODEL} }
881 1008
882 use AnyEvent; 1009 use AnyEvent;
883 1010
1011
884=head1 SEE ALSO 1012=head1 SEE ALSO
885 1013
886Event modules: L<Coro::EV>, L<EV>, L<EV::Glib>, L<Glib::EV>, 1014Event modules: L<Coro::EV>, L<EV>, L<EV::Glib>, L<Glib::EV>,
887L<Coro::Event>, L<Event>, L<Glib::Event>, L<Glib>, L<Coro>, L<Tk>, 1015L<Coro::Event>, L<Event>, L<Glib::Event>, L<Glib>, L<Coro>, L<Tk>,
888L<Event::Lib>, L<Qt>, L<POE>. 1016L<Event::Lib>, L<Qt>, L<POE>.
892L<AnyEvent::Impl::Tk>, L<AnyEvent::Impl::Perl>, L<AnyEvent::Impl::EventLib>, 1020L<AnyEvent::Impl::Tk>, L<AnyEvent::Impl::Perl>, L<AnyEvent::Impl::EventLib>,
893L<AnyEvent::Impl::Qt>, L<AnyEvent::Impl::POE>. 1021L<AnyEvent::Impl::Qt>, L<AnyEvent::Impl::POE>.
894 1022
895Nontrivial usage examples: L<Net::FCP>, L<Net::XMPP2>. 1023Nontrivial usage examples: L<Net::FCP>, L<Net::XMPP2>.
896 1024
1025
897=head1 AUTHOR 1026=head1 AUTHOR
898 1027
899 Marc Lehmann <schmorp@schmorp.de> 1028 Marc Lehmann <schmorp@schmorp.de>
900 http://home.schmorp.de/ 1029 http://home.schmorp.de/
901 1030

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines