procesamiento paralelo simple en perl

Question

Tengo algunos bloques de código, dentro de una función de algún objeto, que pueden correr en paralelo y acelerar las cosas para mí.

He intentado utilizar subs::parallel de la siguiente manera (todo esto es en un cuerpo de una función):

my $is_a_done = parallelize { 
           # block a, do some work 
           return 1; 
          }; 
my $is_b_done = parallelize { 
           # block b, do some work 
           return 1; 
          }; 
my $is_c_done = parallelize { 
           # block c depends on a so let's wait (block) 
           if ($is_a_done) { 
           # do some work 
           }; 
           return 1; 
          }; 
my $is_d_done = parallelize { 
           # block d, do some work 
           return 1; 
          }; 

if ($is_a_done && $is_b_done && $is_c_done && $is_d_done) { 
# just wait for all to finish before the function returns 
} 

En primer lugar, observe que uso if que esperar a que las discusiones para bloquear y esperar hilo anterior a terminar cuando sea necesario (una mejor idea? el if es bastante feo ...).

En segundo lugar, me sale un error:

Thread already joined at /usr/local/share/perl/5.10.1/subs/parallel.pm line 259. 
Perl exited with active threads: 
    1 running and unjoined 
    -1 finished and unjoined 
    3 running and detached 

Answer 1

No he visto subs::parallel antes, pero teniendo en cuenta que se está haciendo todo el manejo para que el hilo, y parece estar haciéndolo mal, basado en el mensaje de error, creo que es un poco sospechoso.

Normalmente no recomendaría tirarlo así, pero lo que está haciendo realmente no es ningún más difícil con la interfaz de hilos lisos, así que ¿por qué no darle una oportunidad y simplificar el problema de una ¿poco? Al mismo tiempo, le daré una respuesta a la otra parte de su pregunta.

use threads; 
my @jobs; 
push @jobs, threads->create(sub { 
    # do some work 
}); 

push @jobs, threads->create(sub { 
    # do some other work 
}); 

# Repeat as necessary :) 

$_->join for @jobs; # Wait for everything to finish. 

necesita algo un poco más complicado si está usando los valores de retorno de esos submarinos (simplemente cambiando a un hash ayudaría mucho), pero en el ejemplo de código que ya ha proporcionado, estás ignorando ellos, lo que hace las cosas fáciles.