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

Comparing AnyEvent-Fork-Pool/Pool.pm (file contents):
Revision 1.6 by root, Sun Apr 21 11:17:02 2013 UTC vs.
Revision 1.7 by root, Sun Apr 21 12:03:02 2013 UTC

       $proc->[0]
          or --$nidle;
       Array::Heap::splice_heap_idx @pool, $proc->[1]
          if defined $proc->[1];
+      @$proc = 0; # tell others to leave it be
    };
    $want_start = sub {
       undef $stop_w;
    };
    $scheduler = sub {
       if (@queue) {
          while (@queue) {
+            @pool or $start_worker->();
             my $proc = $pool[0];
             if ($proc->[0] < $load) {
                # found free worker, increase load
                unless ($proc->[0]++) {
                      or $want_stop->();
                   Array::Heap::adjust_heap_idx @pool, $proc->[1]
                      if defined $proc->[1];
+                  &$ocb;
                   $scheduler->();
-                  &$ocb;
                });
             } else {
                $want_start->()
                   unless @pool >= $max;
 having only one worker is best, for example, when you read or write big
 files at maixmum speed, as a second worker will increase seek times.
 =back
+=head1 EXCEPTIONS
+The same "policy" as with L<AnyEvent::Fork::RPC> applies - exceptins will
+not be caught, and exceptions in both worker and in callbacks causes
+undesirable or undefined behaviour.
 =head1 SEE ALSO
 L<AnyEvent::Fork>, to create the processes in the first place.
 L<AnyEvent::Fork::RPC>, which implements the RPC protocol and API.

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