Jak ograniczyć maksymalną liczbę równoległych wątków w perlu

Question

Mam program (Perl), który uruchamia ogromną ilość wątków (każdy odpowiedzialny za tworzenie grafiki w oparciu o przetwarzanie danych). Każdy wątek zacząć używać:

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

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

Nitki wystrzelić poprawnie, ale po jakimś czasie, gdy mam otwarte kilka z nich ulega awarii Perl interpreter (zakładam, że jest związany z pamięci?). Więc moim rozwiązaniem jest ograniczenie liczby wątków, które otwieram na raz, wybrałem 15. I chcę dodać sub przed każdą linią utwórz, aby sprawdzić, czy można wystrzelić kolejny wątek lub wykonać uśpienie podczas oczekiwania dla jednego do końca. Tak właśnie próbowałem to zrobić.

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; 
     } 
    } 
} 

Więc za każdym razem Chcę utworzyć nowy wątek chciałbym po prostu zadzwoń

&checkThreads; 

A to zadbać, aby tworzyć opóźnienie podczas czekam na niektóre wątki, aby oczyścić. Problemem jest to, że gdy zgłoszę że sub moment uderzę linię gdzie mogę sprawdzić:

$task->is_running() 

program wychodzi i przestanie działać bez jakiegokolwiek błędu lub ostrzeżenia. Chcę tylko sub, który liczy działające wątki, aby je ograniczyć.

Jak mogę skutecznie wykonać tę liczbę?

Inne rzeczy próbowałem oceniamy następującą linię:

scalar(threads->list()); 

Ale to daje mi wartość dziwne, jak to jest unblessed odniesienia wierzę, że wygląda tak:

threads=SCALAR(0x80fea8c) 

Answer 1

Thread::Semaphore zapewnia counting semaphore ograniczyć współbieżności:

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; 

iw swojej funkcji:

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 

Innymi słowy, dowiedz się, ile pozycji znajduje się na liście, którą wątki-> lista() zwraca i masz swoją liczbę.

Być może zechcesz zbadać Thread::Pool lub inne pakiety cpan, aby sprawdzić, czy ktoś już wykonał dla ciebie ciężki lifting.

Answer 3

Patrząc Dokumentów,

my $count = threads->list(); 

powinny działać, wbrew temu, co mówisz. Co używają dokumenty dla wersji wątków , którą używasz? Cóż, możesz użyć poniższego jako obejścia.

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