Gwinty Perla: jak zrobić producenta?

Question

Mam funkcję, która działa bardzo wolno. Potrzebuję danych wejściowych z tej funkcji w głównej części programu. Tak więc chciałbym zrobić coś podobnego do polecenia UNIX yes, które produkuje tyle danych wejściowych, ile jest przeczytanych, ale tylko trochę więcej niż jest potrzebne. W przeciwieństwie do yes nie chcę wartości od STDIN, ale chcę wartości w kolejce Perl.

Innymi słowy: Ten problem nie dotyczy wybrania na uchwytach plików, ale w kolejkach obsługiwanych przez wątki.

Wyobrażam kod meta będzie wyglądał podobnie do tego:

my $DataQueue = Thread::Queue->new(); 

my @producers; 
my $no_of_threads = 10; 
for (1..$no_of_threads) { 
    push @producers, threads->create(\&producer); 
} 

for(<>) { 
    # This should block until there is a value to dequeue 
    # Maybe dequeue blocks by default - then this part is not a problem 
    my $val = $DataQueue->dequeue(); 
    do_something($_,$val); 
} 
# We are done: The producers are no longer needed 
kill @producers; 

sub producer { 
    while(1) { 
     # How do I wait until the queue length is smaller than number of threads? 
     wait_until(length of $DataQueue < $no_of_threads); 
     $DataQueue->enqueue(compute_slow_value()); 
    } 
} 

Ale czy istnieje bardziej elegancki sposób to zrobić? Nie jestem szczególnie pewien, jak wykonać część wait_until w efektywny sposób.

Answer 1

Coś jak to prawdopodobnie będzie działać:

my $DataQueue = Thread::Queue->new(); 

my @producers; 
my $no_of_threads = 10; 
for (1..$no_of_threads) { 
    push @producers, threads->create(\&producer); 
} 
$DataQueue->limit = 2 * $no_of_threads; 

for(<>) { 
    # This blocks until $DataQueue->pending > 0 
    my $val = $DataQueue->dequeue(); 
    do_something($_,$val); 
} 
# We are done: The producers are no longer needed 
kill @producers; 

sub producer { 
    while(1) { 
     # enqueue will block until $DataQueue->pending < $DataQueue->limit 
     $DataQueue->enqueue(compute_slow_value()); 
    } 
}