ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/AnyEvent-Fork/Fork.pm
(Generate patch)

Comparing AnyEvent-Fork/Fork.pm (file contents):
Revision 1.35 by root, Sat Apr 6 09:39:12 2013 UTC vs.
Revision 1.41 by root, Mon Apr 8 03:20:53 2013 UTC

27 27
28Special care has been taken to make this module useful from other modules, 28Special care has been taken to make this module useful from other modules,
29while still supporting specialised environments such as L<App::Staticperl> 29while still supporting specialised environments such as L<App::Staticperl>
30or L<PAR::Packer>. 30or L<PAR::Packer>.
31 31
32=head1 WHAT THIS MODULE IS NOT 32=head2 WHAT THIS MODULE IS NOT
33 33
34This module only creates processes and lets you pass file handles and 34This module only creates processes and lets you pass file handles and
35strings to it, and run perl code. It does not implement any kind of RPC - 35strings to it, and run perl code. It does not implement any kind of RPC -
36there is no back channel from the process back to you, and there is no RPC 36there is no back channel from the process back to you, and there is no RPC
37or message passing going on. 37or message passing going on.
40in whatever way you like, use some message-passing module such 40in whatever way you like, use some message-passing module such
41as L<AnyEvent::MP>, some pipe such as L<AnyEvent::ZeroMQ>, use 41as L<AnyEvent::MP>, some pipe such as L<AnyEvent::ZeroMQ>, use
42L<AnyEvent::Handle> on both sides to send e.g. JSON or Storable messages, 42L<AnyEvent::Handle> on both sides to send e.g. JSON or Storable messages,
43and so on. 43and so on.
44 44
45=head2 COMPARISON TO OTHER MODULES
46
47There is an abundance of modules on CPAN that do "something fork", such as
48L<Parallel::ForkManager>, L<AnyEvent::ForkManager>, L<AnyEvent::Worker>
49or L<AnyEvent::Subprocess>. There are modules that implement their own
50process management, such as L<AnyEvent::DBI>.
51
52The problems that all these modules try to solve are real, however, none
53of them (from what I have seen) tackle the very real problems of unwanted
54memory sharing, efficiency, not being able to use event processing or
55similar modules in the processes they create.
56
57This module doesn't try to replace any of them - instead it tries to solve
58the problem of creating processes with a minimum of fuss and overhead (and
59also luxury). Ideally, most of these would use AnyEvent::Fork internally,
60except they were written before AnyEvent:Fork was available, so obviously
61had to roll their own.
62
45=head1 PROBLEM STATEMENT 63=head2 PROBLEM STATEMENT
46 64
47There are two traditional ways to implement parallel processing on UNIX 65There are two traditional ways to implement parallel processing on UNIX
48like operating systems - fork and process, and fork+exec and process. They 66like operating systems - fork and process, and fork+exec and process. They
49have different advantages and disadvantages that I describe below, 67have different advantages and disadvantages that I describe below,
50together with how this module tries to mitigate the disadvantages. 68together with how this module tries to mitigate the disadvantages.
212 open my $output, ">/tmp/log" or die "$!"; 230 open my $output, ">/tmp/log" or die "$!";
213 231
214 AnyEvent::Fork 232 AnyEvent::Fork
215 ->new 233 ->new
216 ->eval (' 234 ->eval ('
235 # compile a helper function for later use
217 sub run { 236 sub run {
218 my ($fh, $output, @cmd) = @_; 237 my ($fh, $output, @cmd) = @_;
219 238
220 # perl will clear close-on-exec on STDOUT/STDERR 239 # perl will clear close-on-exec on STDOUT/STDERR
221 open STDOUT, ">&", $output or die; 240 open STDOUT, ">&", $output or die;
351use AnyEvent; 370use AnyEvent;
352use AnyEvent::Util (); 371use AnyEvent::Util ();
353 372
354use IO::FDPass; 373use IO::FDPass;
355 374
356our $VERSION = 0.5; 375our $VERSION = 0.6;
357
358our $PERL; # the path to the perl interpreter, deduces with various forms of magic
359 376
360=over 4 377=over 4
361 378
362=back 379=back
363 380
442 if ($pid eq 0) { 459 if ($pid eq 0) {
443 require AnyEvent::Fork::Serve; 460 require AnyEvent::Fork::Serve;
444 $AnyEvent::Fork::Serve::OWNER = $parent; 461 $AnyEvent::Fork::Serve::OWNER = $parent;
445 close $fh; 462 close $fh;
446 $0 = "$_[1] of $parent"; 463 $0 = "$_[1] of $parent";
447 $SIG{CHLD} = 'IGNORE';
448 AnyEvent::Fork::Serve::serve ($slave); 464 AnyEvent::Fork::Serve::serve ($slave);
449 exit 0; 465 exit 0;
450 } elsif (!$pid) { 466 } elsif (!$pid) {
451 die "AnyEvent::Fork::Early/Template: unable to fork template process: $!"; 467 die "AnyEvent::Fork::Early/Template: unable to fork template process: $!";
452 } 468 }
780 479 vfork+execs per second, using AnyEvent::Fork->new_exec 796 479 vfork+execs per second, using AnyEvent::Fork->new_exec
781 797
782So how can C<< AnyEvent->new >> be faster than a standard fork, even 798So how can C<< AnyEvent->new >> be faster than a standard fork, even
783though it uses the same operations, but adds a lot of overhead? 799though it uses the same operations, but adds a lot of overhead?
784 800
785The difference is simply the process size: forking the 6MB process takes 801The difference is simply the process size: forking the 5MB process takes
786so much longer than forking the 2.5MB template process that the overhead 802so much longer than forking the 2.5MB template process that the extra
787introduced is canceled out. 803overhead introduced is canceled out.
788 804
789If the benchmark process grows, the normal fork becomes even slower: 805If the benchmark process grows, the normal fork becomes even slower:
790 806
791 1340 new processes, manual fork in a 20MB process 807 1340 new processes, manual fork of a 20MB process
792 731 new processes, manual fork in a 200MB process 808 731 new processes, manual fork of a 200MB process
793 235 new processes, manual fork in a 2000MB process 809 235 new processes, manual fork of a 2000MB process
794 810
795What that means (to me) is that I can use this module without having a 811What that means (to me) is that I can use this module without having a bad
796very bad conscience because of the extra overhead required to start new 812conscience because of the extra overhead required to start new processes.
797processes.
798 813
799=head1 TYPICAL PROBLEMS 814=head1 TYPICAL PROBLEMS
800 815
801This section lists typical problems that remain. I hope by recognising 816This section lists typical problems that remain. I hope by recognising
802them, most can be avoided. 817them, most can be avoided.
803 818
804=over 4 819=over 4
805 820
806=item "leaked" file descriptors for exec'ed processes 821=item leaked file descriptors for exec'ed processes
807 822
808POSIX systems inherit file descriptors by default when exec'ing a new 823POSIX systems inherit file descriptors by default when exec'ing a new
809process. While perl itself laudably sets the close-on-exec flags on new 824process. While perl itself laudably sets the close-on-exec flags on new
810file handles, most C libraries don't care, and even if all cared, it's 825file handles, most C libraries don't care, and even if all cared, it's
811often not possible to set the flag in a race-free manner. 826often not possible to set the flag in a race-free manner.
831libraries or the code that leaks those file descriptors. 846libraries or the code that leaks those file descriptors.
832 847
833Fortunately, most of these leaked descriptors do no harm, other than 848Fortunately, most of these leaked descriptors do no harm, other than
834sitting on some resources. 849sitting on some resources.
835 850
836=item "leaked" file descriptors for fork'ed processes 851=item leaked file descriptors for fork'ed processes
837 852
838Normally, L<AnyEvent::Fork> does start new processes by exec'ing them, 853Normally, L<AnyEvent::Fork> does start new processes by exec'ing them,
839which closes file descriptors not marked for being inherited. 854which closes file descriptors not marked for being inherited.
840 855
841However, L<AnyEvent::Fork::Early> and L<AnyEvent::Fork::Template> offer 856However, L<AnyEvent::Fork::Early> and L<AnyEvent::Fork::Template> offer
850 865
851The solution is to either not load these modules before use'ing 866The solution is to either not load these modules before use'ing
852L<AnyEvent::Fork::Early> or L<AnyEvent::Fork::Template>, or to delay 867L<AnyEvent::Fork::Early> or L<AnyEvent::Fork::Template>, or to delay
853initialising them, for example, by calling C<init Gtk2> manually. 868initialising them, for example, by calling C<init Gtk2> manually.
854 869
855=item exit runs destructors 870=item exiting calls object destructors
856 871
857This only applies to users of Lc<AnyEvent::Fork:Early> and 872This only applies to users of L<AnyEvent::Fork:Early> and
858L<AnyEvent::Fork::Template>. 873L<AnyEvent::Fork::Template>, or when initialiasing code creates objects
874that reference external resources.
859 875
860When a process created by AnyEvent::Fork exits, it might do so by calling 876When a process created by AnyEvent::Fork exits, it might do so by calling
861exit, or simply letting perl reach the end of the program. At which point 877exit, or simply letting perl reach the end of the program. At which point
862Perl runs all destructors. 878Perl runs all destructors.
863 879
882to make it so, mostly due to the bloody broken perl that nobody seems to 898to make it so, mostly due to the bloody broken perl that nobody seems to
883care about. The fork emulation is a bad joke - I have yet to see something 899care about. The fork emulation is a bad joke - I have yet to see something
884useful that you can do with it without running into memory corruption 900useful that you can do with it without running into memory corruption
885issues or other braindamage. Hrrrr. 901issues or other braindamage. Hrrrr.
886 902
887Cygwin perl is not supported at the moment, as it should implement fd 903Cygwin perl is not supported at the moment due to some hilarious
888passing, but doesn't, and rolling my own is hard, as cygwin doesn't 904shortcomings of its API - see L<IO::FDPoll> for more details.
889support enough functionality to do it.
890 905
891=head1 SEE ALSO 906=head1 SEE ALSO
892 907
893L<AnyEvent::Fork::Early> (to avoid executing a perl interpreter), 908L<AnyEvent::Fork::Early> (to avoid executing a perl interpreter),
894L<AnyEvent::Fork::Template> (to create a process by forking the main 909L<AnyEvent::Fork::Template> (to create a process by forking the main

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines