[ViewVC] Diff of: cvs/AnyEvent/lib/AnyEvent.pm

Comparing AnyEvent/lib/AnyEvent.pm (file contents):
Revision 1.129 by elmex, Sat May 24 15:19:30 2008 UTC vs.
Revision 1.140 by root, Mon May 26 06:18:53 2008 UTC

 >> method, usually without arguments. The only argument pair allowed is
 C<cb>, which specifies a callback to be called when the condition variable
 becomes true.
 After creation, the condition variable is "false" until it becomes "true"
-by calling the C<send> method.
+by calling the C<send> method (or calling the condition variable as if it
+were a callback, read about the caveats in the description for the C<<
+->send >> method).
 Condition variables are similar to callbacks, except that you can
 optionally wait for them. They can also be called merge points - points
 in time where multiple outstanding events have been processed. And yet
 another way to call them is transactions - each condition variable can be
 There are two "sides" to a condition variable - the "producer side" which
 eventually calls C<< -> send >>, and the "consumer side", which waits
 for the send to occur.
-Example:
+Example: wait for a timer.
    # wait till the result is ready
    my $result_ready = AnyEvent->condvar;
    # do something such as adding a timer
    # this "blocks" (while handling events) till the callback
    # calls send
    $result_ready->recv;
+Example: wait for a timer, but take advantage of the fact that
+condition variables are also code references.
+   my $done = AnyEvent->condvar;
+   my $delay = AnyEvent->timer (after => 5, cb => $done);
+   $done->recv;
 =head3 METHODS FOR PRODUCERS
 These methods should only be used by the producing side, i.e. the
 code/module that eventually sends the signal. Note that it is also
 the producer side which creates the condvar in most cases, but it isn't
 If a callback has been set on the condition variable, it is called
 immediately from within send.
 Any arguments passed to the C<send> call will be returned by all
 future C<< ->recv >> calls.
+Condition variables are overloaded so one can call them directly
+(as a code reference). Calling them directly is the same as calling
+C<send>. Note, however, that many C-based event loops do not handle
+overloading, so as tempting as it may be, passing a condition variable
+instead of a callback does not work. Both the pure perl and EV loops
+support overloading, however, as well as all functions that use perl to
+invoke a callback (as in L<AnyEvent::Socket> and L<AnyEvent::DNS> for
+example).
 =item $cv->croak ($error)
 Similar to send, but causes all call's to C<< ->recv >> to invoke
 C<Carp::croak> with the given error message/object/scalar.
 If it doesn't care, it can just "use AnyEvent" and use it itself, or not
 do anything special (it does not need to be event-based) and let AnyEvent
 decide which implementation to chose if some module relies on it.
-If the main program relies on a specific event model. For example, in
+If the main program relies on a specific event model - for example, in
-Gtk2 programs you have to rely on the Glib module. You should load the
+Gtk2 programs you have to rely on the Glib module - you should load the
 event module before loading AnyEvent or any module that uses it: generally
 speaking, you should load it as early as possible. The reason is that
 modules might create watchers when they are loaded, and AnyEvent will
 decide on the event model to use as soon as it creates watchers, and it
 might chose the wrong one unless you load the correct one yourself.
-You can chose to use a rather inefficient pure-perl implementation by
+You can chose to use a pure-perl implementation by loading the
-loading the C<AnyEvent::Impl::Perl> module, which gives you similar
+C<AnyEvent::Impl::Perl> module, which gives you similar behaviour
-behaviour everywhere, but letting AnyEvent chose is generally better.
+everywhere, but letting AnyEvent chose the model is generally better.
+=head2 MAINLOOP EMULATION
+Sometimes (often for short test scripts, or even standalone programs who
+only want to use AnyEvent), you do not want to run a specific event loop.
+In that case, you can use a condition variable like this:
+   AnyEvent->condvar->recv;
+This has the effect of entering the event loop and looping forever.
+Note that usually your program has some exit condition, in which case
+it is better to use the "traditional" approach of storing a condition
+variable somewhere, waiting for it, and sending it when the program should
+exit cleanly.
 =head1 OTHER MODULES
 The following is a non-exhaustive list of additional modules that use
 AnyEvent and can therefore be mixed easily with other AnyEvent modules
 Provides various utility functions for (internet protocol) sockets,
 addresses and name resolution. Also functions to create non-blocking tcp
 connections or tcp servers, with IPv6 and SRV record support and more.
+=item L<AnyEvent::DNS>
+Provides rich asynchronous DNS resolver capabilities.
 =item L<AnyEvent::HTTPD>
 Provides a simple web application server framework.
-=item L<AnyEvent::DNS>
-Provides rich asynchronous DNS resolver capabilities.
 =item L<AnyEvent::FastPing>
 The fastest ping in the west.
 no warnings;
 use strict;
 use Carp;
-our $VERSION = '3.6';
+our $VERSION = '4.04';
 our $MODEL;
 our $AUTOLOAD;
 our @ISA;
+our @REGISTRY;
+our $WIN32;
+BEGIN {
+   my $win32 = ! ! ($^O =~ /mswin32/i);
+   eval "sub WIN32(){ $win32 }";
+}
 our $verbose = $ENV{PERL_ANYEVENT_VERBOSE}*1;
-our @REGISTRY;
+our %PROTOCOL; # (ipv4|ipv6) => (1|2), higher numbers are preferred
-our %PROTOCOL; # (ipv4|ipv6) => (1|2)
 {
    my $idx;
    $PROTOCOL{$_} = ++$idx
+      for reverse split /\s*,\s*/,
-      for split /\s*,\s*/, $ENV{PERL_ANYEVENT_PROTOCOLS} || "ipv4,ipv6";
+             $ENV{PERL_ANYEVENT_PROTOCOLS} || "ipv4,ipv6";
 }
 my @models = (
    [EV::                   => AnyEvent::Impl::EV::],
    [Event::                => AnyEvent::Impl::Event::],
-   [Tk::                   => AnyEvent::Impl::Tk::],
-   [Wx::                   => AnyEvent::Impl::POE::],
-   [Prima::                => AnyEvent::Impl::POE::],
    [AnyEvent::Impl::Perl:: => AnyEvent::Impl::Perl::],
-   # everything below here will not be autoprobed as the pureperl backend should work everywhere
+   # everything below here will not be autoprobed
-   [Glib::                 => AnyEvent::Impl::Glib::],
+   # as the pureperl backend should work everywhere
+   # and is usually faster
+   [Tk::                   => AnyEvent::Impl::Tk::],       # crashes with many handles
+   [Glib::                 => AnyEvent::Impl::Glib::],     # becomes extremely slow with many watchers
    [Event::Lib::           => AnyEvent::Impl::EventLib::], # too buggy
    [Qt::                   => AnyEvent::Impl::Qt::],       # requires special main program
    [POE::Kernel::          => AnyEvent::Impl::POE::],      # lasciate ogni speranza
+   [Wx::                   => AnyEvent::Impl::POE::],
+   [Prima::                => AnyEvent::Impl::POE::],
 );
 our %method = map +($_ => 1), qw(io timer signal child condvar one_event DESTROY);
 our @post_detect;
 }
 sub detect() {
    unless ($MODEL) {
       no strict 'refs';
+      local $SIG{__DIE__};
       if ($ENV{PERL_ANYEVENT_MODEL} =~ /^([a-zA-Z]+)$/) {
          my $model = "AnyEvent::Impl::$1";
          if (eval "require $model") {
             $MODEL = $model;
       or Carp::croak "required option 'pid' is missing";
    $PID_CB{$pid}{$arg{cb}} = $arg{cb};
    unless ($WNOHANG) {
-      $WNOHANG = eval { require POSIX; &POSIX::WNOHANG } || 1;
+      $WNOHANG = eval { local $SIG{__DIE__}; require POSIX; &POSIX::WNOHANG } || 1;
    }
    unless ($CHLD_W) {
       $CHLD_W = AnyEvent->signal (signal => 'CHLD', cb => \&_sigchld);
       # child could be a zombie already, so make at least one round
 package AnyEvent::CondVar;
 our @ISA = AnyEvent::CondVar::Base::;
 package AnyEvent::CondVar::Base;
+use overload
+   '&{}'    => sub { my $self = shift; sub { $self->send (@_) } },
+   fallback => 1;
 sub _send {
    # nop
 }

Diff Legend

-–
+Removed lines
-+
+Added lines
-<
+Changed lines
->
+Changed lines

Comparing AnyEvent/lib/AnyEvent.pm (file contents): Revision 1.129 by elmex, Sat May 24 15:19:30 2008 UTC vs. Revision 1.140 by root, Mon May 26 06:18:53 2008 UTC

Diff Legend

Comparing AnyEvent/lib/AnyEvent.pm (file contents):
Revision 1.129 by elmex, Sat May 24 15:19:30 2008 UTC vs.
Revision 1.140 by root, Mon May 26 06:18:53 2008 UTC