¿Cómo ejecutar hilos concurrentes en perl?

Question

El siguiente no parece funcionar en hilos concurrentes como esperaba, sino que cada bloques de proceso hasta que es completa:

my @arr = (1,2,3,4); 
foreach (@arr) { 
    threads->new(\&doSomething, $_)->join; 
} 

sub doSomething { 
    my $thread = shift; 
    print "thread $thread\n"; 
    sleep(5); 
} 

En otras palabras, parece ser la ejecución de la misma que la versión no roscada haría:

my @arr = (1,2,3,4); 
foreach (@arr) { 
    doSomething($_); 
} 

estoy corriendo ActivePerl v5.10.1 mswin32-x86-multi-hilo

Cómo corro hilos concurrentes en perl?

Answer 1

Ver perldoc threads.

El problema es que al llamar a join() en un hilo espera a que termine. Desea engendrar hilos y luego unirse después, no engendrar/unirse como una sola operación.

Una mirada más a fondo en perldoc threads dice:

threads-> lista()

threads-> lista (hilos) :: todas

threads-> lista (hilos de ejecución ::)

threads-> lista (hilos) que se pueden unir ::

Sin argumentos (o usando threads :: all) y en un contexto de lista, devuelve una lista de todos los objetos de subprocesos no unidos no unidos. En un contexto escalar, devuelve un conteo del mismo.

Con un verdadero argumento (utilizando hilos :: funcionamiento) , devuelve una lista de todos, hilos no unifamiliar objetos no afiliados que se aún en marcha.

Con un argumento falso (usando threads :: joinable), devuelve una lista de todos los objetos de hilos no unidos, no separados que han terminado de ejecutarse (es decir, para los que -> join() no se bloqueará).

Usted puede usar esto para hilos de bucle y de la lista, uniéndose cuando sea posible, hasta que todos los hilos están completas (y probablemente querrá un límite superior para el tiempo de espera donde se matarlos y abortar)

Answer 2

join (no solo en Perl) provoca que el subproceso de llamada espere a que finalice otro subproceso. Por lo tanto, su ejemplo engendra el hilo, espera que termine y luego genera otro hilo, por lo que se da la impresión de que no hay ningún hilo engendrado.

Answer 3

usted tiene que unirse a ellos después, no mientras la creación de ellos:

my @arr = (1,2,3,4); 
my @threads; 
foreach (@arr) { 
    push @threads, threads->new(\&doSomething, $_); 
} 
foreach (@threads) { 
    $_->join(); 
} 

Answer 4

Tienes que llamar joindespués desove todas las discusiones:

perl -mthreads -le'$_->join for map threads->new(sub{print"Thread $_";sleep(2)}),1..4' 

Answer 5

Si usted no cuida de la salida generada desde el hilo, puede usar -> detach() en el hilo.

my @arr = (1,2,3,4); my @threads; foreach (@arr) {
my $ t = hilos-> nuevo (\ & doSomething, $ _); $ t-> detach(); }

después de completar un hilo, se recupera y no necesita llamar a join() en él.

este modelo es bueno para crear abejas trabajadoras que no necesita informarle.

Answer 6

my @arr = (1,2,3,4); 
my @threads; 
foreach (@arr) { 
    push @threads, threads->new(\&doSomething, $_); 
} 
foreach (@threads) { 
    $_->join(); 
} 

El código anterior funciona a pequeña escala. Pero si tiene decenas de hilos o más, su sistema operativo comienza a estancarse.