Come limitare il numero massimo di thread paralleli in perl

Question

Ho un programma (Perl) che prende il via una quantità enorme di fili (ognuno incaricato di creare grafica basata sul trattamento dei dati). Ogni thread comincio utilizzando:

my @threads //list to store threads that have been launched 

push @threads,threads->create(\mySubName,params...); 

I fili fuoco spento correttamente, ma dopo un po ', dopo aver aperto alcuni di loro crash dell'interprete Perl (suppongo che è legato alla memoria?). Quindi la mia soluzione è quella di limitare il numero di thread apro alla volta, ho preso 15. E voglio aggiungere un sub prima di ogni linea di creare per controllare se è ok per sparare il filo successivo o eseguire un sonno mentre aspetto per uno per finire. Questo è il modo in cui ho provato a farlo.

sub checkThreads{ 
    my $addThread = 0; 
    until($addThread){ 
     my $totalThreads = 0; 
     foreach my $task (@threads){ 
      if($task->is_running()){$totalThreads++;} 
     } 
     if($totalThreads <= 15){ 
      print "Ok to add new thread, carry on!\n"; 
      $addthread = 1; 
     }else{ 
      print "Waiting for $totalThreads threads to fire next one...\n"; 
      sleep 2; 
     } 
    } 
} 

Così ogni volta che voglio creare un nuovo thread vorrei solo richiamare

&checkThreads; 

E che si sarebbe preso cura di creare un ritardo mentre aspetto che alcuni fili per ripulire. Il problema è che quando chiamo che sub, il momento in cui mi ha colpito la linea dove verifico:

$task->is_running() 

il programma termina e smette di funzionare senza alcun errore o avviso. Voglio solo un sub che conti i thread in esecuzione per limitarli.

Come posso eseguire questo conteggio con successo?

Altre cose che ho provato stanno valutando la seguente riga:

scalar(threads->list()); 

ma che mi dà un valore di strano, come si tratta di un riferimento unblessed Credo che assomiglia:

threads=SCALAR(0x80fea8c) 

Answer 1

Thread::Semaphore fornisce un counting semaphore per limitare la concorrenza:

my $sem = Thread::Semaphore->new(15); # max 15 threads 
my @threads = map { 
    # request a thread slot, waiting if none are available: 
    $sem->down; 
    threads->create(\&mySubName, @params) 
} 0..100; 
$_->join for @threads; 

E nella funzione:

sub mySubName { 
    do_stuff(); 
    # release slot: 
    $sem->up; 
} 

Answer 2

man perlthrtut 

What Threads Are Running? 
    "threads->list()" returns a list of thread objects, one for each thread 
    that's currently running and not detached. Handy for a number of 

in altre parole, scoprire quanti elementi sono nella lista che threads-> lista() ritorna e si dispone il valore del tuo.

Si potrebbe voler esaminare Thread::Pool o altri pacchetti cpan per vedere se qualcun altro ha già fatto il lavoro pesante per voi.

Answer 3

cerca i documenti,

my $count = threads->list(); 

dovrebbero lavorare, al contrario di quello che dici. Che cosa la documentazione per la versione di fili si utilizza dire? Bene, è possibile utilizzare il seguente come soluzione alternativa.

my $count =() = threads->list();