[ViewVC] Diff of: cvs/AnyEvent-Fork/Fork.pm

Comparing AnyEvent-Fork/Fork.pm (file contents):
Revision 1.50 by root, Sat Apr 20 19:58:06 2013 UTC vs.
Revision 1.56 by root, Sun Apr 28 13:47:52 2013 UTC

 If you need some form of RPC, you could use the L<AnyEvent::Fork::RPC>
 companion module, which adds simple RPC/job queueing to a process created
 by this module.
+And if you need some automatic process pool management on top of
+L<AnyEvent::Fork::RPC>, you can look at the L<AnyEvent::Fork::Pool>
+companion module.
-Or you can implement it yourself in whatever way you like, use some
+Or you can implement it yourself in whatever way you like: use some
 message-passing module such as L<AnyEvent::MP>, some pipe such as
 L<AnyEvent::ZeroMQ>, use L<AnyEvent::Handle> on both sides to send
 e.g. JSON or Storable messages, and so on.
 =head2 COMPARISON TO OTHER MODULES
       ->send_arg ("/bin/echo", "hi")
       ->run ("run", my $cv = AE::cv);
    my $stderr = $cv->recv;
+=head2 For stingy users: put the worker code into a C<DATA> section.
+When you want to be stingy with files, you cna put your code into the
+C<DATA> section of your module (or program):
+   use AnyEvent::Fork;
+   AnyEvent::Fork
+      ->new
+      ->eval (do { local $/; <DATA> })
+      ->run ("doit", sub { ... });
+   __DATA__
+   sub doit {
+      ... do something!
+   }
+=head2 For stingy standalone programs: do not rely on external files at
+all.
+For single-file scripts it can be inconvenient to rely on external
+files - even when using < C<DATA> section, you still need to C<exec>
+an external perl interpreter, which might not be available when using
+L<App::Staticperl>, L<Urlader> or L<PAR::Packer> for example.
+Two modules help here - L<AnyEvent::Fork::Early> forks a template process
+for all further calls to C<new_exec>, and L<AnyEvent::Fork::Template>
+forks the main program as a template process.
+Here is how your main program should look like:
+   #! perl
+   # optional, as the very first thing.
+   # in case modules want to create their own processes.
+   use AnyEvent::Fork::Early;
+   # next, load all modules you need in your template process
+   use Example::My::Module
+   use Example::Whatever;
+   # next, put your run function definition and anything else you
+   # need, but do not use code outside of BEGIN blocks.
+   sub worker_run {
+      my ($fh, @args) = @_;
+      ...
+   }
+   # now preserve everything so far as AnyEvent::Fork object
+   # in §TEMPLATE.
+   use AnyEvent::Fork::Template;
+   # do not put code outside of BEGIN blocks until here
+   # now use the $TEMPLATE process in any way you like
+   # for example: create 10 worker processes
+   my @worker;
+   my $cv = AE::cv;
+   for (1..10) {
+      $cv->begin;
+      $TEMPLATE->fork->send_arg ($_)->run ("worker_run", sub {
+         push @worker, shift;
+         $cv->end;
+      });
+   }
+   $cv->recv;
 =head1 CONCEPTS
 This module can create new processes either by executing a new perl
 process, or by forking from an existing "template" process.
 use AnyEvent;
 use AnyEvent::Util ();
 use IO::FDPass;
-our $VERSION = 0.7;
+our $VERSION = 1.1;
 # the early fork template process
 our $EARLY;
 # the empty template process
 The path to the perl interpreter is divined using various methods - first
 C<$^X> is investigated to see if the path ends with something that sounds
 as if it were the perl interpreter. Failing this, the module falls back to
 using C<$Config::Config{perlpath}>.
+The path to perl can also be overriden by setting the global variable
+C<$AnyEvent::Fork::PERL> - it's value will be used for all subsequent
+invocations.
 =cut
+our $PERL;
 sub new_exec {
    my ($self) = @_;
    return $EARLY->fork
       if $EARLY;
+   unless (defined $PERL) {
-   # first find path of perl
+      # first find path of perl
-   my $perl = $;
+      my $perl = $;
-   # first we try $^X, but the path must be absolute (always on win32), and end in sth.
+      # first we try $^X, but the path must be absolute (always on win32), and end in sth.
-   # that looks like perl. this obviously only works for posix and win32
+      # that looks like perl. this obviously only works for posix and win32
-   unless (
+      unless (
-      ($^O eq "MSWin32" || $perl =~ m%^/%)
+         ($^O eq "MSWin32" || $perl =~ m%^/%)
-      && $perl =~ m%[/\\]perl(?:[0-9]+(\.[0-9]+)+)?(\.exe)?$%i
+         && $perl =~ m%[/\\]perl(?:[0-9]+(\.[0-9]+)+)?(\.exe)?$%i
-   ) {
+      ) {
-      # if it doesn't look perlish enough, try Config
+         # if it doesn't look perlish enough, try Config
-      require Config;
+         require Config;
-      $perl = $Config::Config{perlpath};
+         $perl = $Config::Config{perlpath};
-      $perl =~ s/(?:\Q$Config::Config{_exe}\E)?$/$Config::Config{_exe}/;
+         $perl =~ s/(?:\Q$Config::Config{_exe}\E)?$/$Config::Config{_exe}/;
+      }
+      $PERL = $perl;
    }
    require Proc::FastSpawn;
    my ($fh, $slave) = AnyEvent::Util::portable_socketpair;
    #local $ENV{PERL5LIB} = join ":", grep !ref, @INC;
    my %env = %ENV;
    $env{PERL5LIB} = join +($^O eq "MSWin32" ? ";" : ":"), grep !ref, @INC;
    my $pid = Proc::FastSpawn::spawn (
-      $perl,
+      $PERL,
       ["perl", "-MAnyEvent::Fork::Serve", "-e", "AnyEvent::Fork::Serve::me", fileno $slave, $$],
       [map "$_=$env{$_}", keys %env],
    ) or die "unable to spawn AnyEvent::Fork server: $!";
    $self->_new ($fh, $pid)
    $self->[CB] = $cb;
    $self->_cmd (r => $func);
 }
+=back
+=head2 EXPERIMENTAL METHODS
+These methods might go away completely or change behaviour, at any time.
+=over 4
 =item $proc->to_fh ($cb->($fh))    # EXPERIMENTAL, MIGHT BE REMOVED
 Flushes all commands out to the process and then calls the callback with
 the communications socket.
 The process object becomes unusable on return from this function - any
 further method calls result in undefined behaviour.
 The point of this method is to give you a file handle thta you cna pass
 to another process. In that other process, you can call C<new_from_fh
-AnyEvent::Fork::RPC> to create a new C<AnyEvent::Fork> object from it,
+AnyEvent::Fork> to create a new C<AnyEvent::Fork> object from it, thereby
-thereby effectively passing a fork object to another process.
+effectively passing a fork object to another process.
 =cut
 sub to_fh {
    my ($self, $cb) = @_;
 L<AnyEvent::Fork::Template>, to create a process by forking the main
 program at a convenient time (part of this distribution).
 L<AnyEvent::Fork::RPC>, for simple RPC to child processes (on CPAN).
+L<AnyEvent::Fork::Pool>, for simple worker process pool (on CPAN).
 =head1 AUTHOR AND CONTACT INFORMATION
  Marc Lehmann <schmorp@schmorp.de>
  http://software.schmorp.de/pkg/AnyEvent-Fork

Diff Legend

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

Comparing AnyEvent-Fork/Fork.pm (file contents): Revision 1.50 by root, Sat Apr 20 19:58:06 2013 UTC vs. Revision 1.56 by root, Sun Apr 28 13:47:52 2013 UTC

Diff Legend

Comparing AnyEvent-Fork/Fork.pm (file contents):
Revision 1.50 by root, Sat Apr 20 19:58:06 2013 UTC vs.
Revision 1.56 by root, Sun Apr 28 13:47:52 2013 UTC