Добрый день,
Хочу сделать многопоточную обработку файлов. Проблема в том, что не соображу, как сделать, чтобы не сразу запускать N потоков, как тут. А чтобы работало, к примеру, 5 потоков и по мере их окончания запускались еще 5... и так пока не кончатся данные для обработки. Подскажите, в виде общего каркаса кода.
use threads;
my @threads;
my @files=qw(1111.txt 2222.txt 3333.txt 4444.txt 5555.txt 6666.txt 7777.txt 88888.txt 99999.txt 000000.txt);
my $max_threads=5; # макс. число одновременно работающих потоков
foreach my $file (@files)
{
push @threads, threads->create(\&getfile, $file); # так мы запустим потоков столько сколько записей в массиве, а надо типа очереди, чтото
}
foreach my $thread (@threads)
{
$thread->join();
}
sub getfile{
my $file=shift;
print $file."\n";
}