你最近有用的Perl单线程(或涉及Perl的管道)是什么？

use threads;
use threads::shared;
use threads::queue;

# 初始化一个空的哈希表，便于使用线程间的共享数据
my %shared;

# 初始化一个空的管道
my $pipe_file = \*ARGV[-1];
open my $pipe_FH, ">>", $pipe_file or die "打开管道失败: $!";
close $pipe_FH;

# 定义一个函数，执行输入文件的内容，并添加时间信息
sub process_input {
    my ($cmd, %input) = @_;
    my @output = `$cmd`;
    my $time_info = join ', ', @output[grep !/^\s*[a-z0-9]/, 0..$#output]; # 提取时间信息
    my $message = "$input{cmd} on $time_info took " . (time - $^T) . " seconds.\n";
    $shared{$message} = $time_info; # 添加共享值
    $| = 1; # 启动管道缓冲区
}

# 生产者在Perl 线程 0上运行
my $q = threads::queue->new; # 使用一个空的队列来控制生产者的进度（即，创建线程）
foreach my $file (@ARGV) {
    open my $file_FH, "<", $file or die "打开文件失败: $!";
    next if eof $file_FH;  # 忽略空文件
    readline $file_FH; # 继续读取文件内容直到文件结束
    push $q, {cmd => "./your/expensive/processing/*.pl", input => {file => $file}};
}

my $t = threads->create(\&process_input, "cat", \%shared); # 生产者提交命令和共享的数据到生产者线程0
my $pid = $$ # 保存当前进程的 pid，用于停止后检查
while !$q->empty {
    $| = 1; # 启用管道缓冲区
    my $task = $q->dequeue_nb; # 取出任务并执行
    my @result = do $task->{cmd} || die "无法运行脚本: $!"; # 运行执行命令
    print join "\n", @result if $task->{input}->{file}; # 将输出打印到文件中
    close STDIN;  # 关闭输入文件并清理文件句柄
    close STDOUT; # 关闭标准输出文件并清理文件句柄
    close STDERR; # 关闭错误输出文件并清理文件句柄

    # 停止线程
    print "$pid finished processing " . $task->{input}->{file} . "\n";
    close $pipe_file; # 关闭管道文件
    exit(0);
}
threads->exit(); # 停止所有线程并释放内存

$q->join(); # 等待所有进程或线程完成执行

# 打印平均输出速度
my @times = values %shared;
my $average = (sum(@times, 0) / scalar @times) . "\n";
print "Average CPU time for this job: @$average seconds\n";

perl perl_script.pl input.txt > output.txt