raku - 如何控制线程数？

Question

#The @url.elems >= 10000
    for @url -> $url {
       start {
          say $url;
          sleep(1);
       }
    }

如何控制线程数？

Answer 1

在回答问题之前:您展示的代码丢失了Promise返回者 start .你可能想要:

await do for @url -> $url {
   start {
      say $url;
      sleep(1);
   }
}

这将等到所有启动块都完成。

回到你的问题:环境变量 RAKUDO_MAX_THREADS可以在运行程序之前设置为将创建的最大线程数(默认为 16)。

另一种在运行时也有效的方法是动态创建一个新的 ThreadPoolScheduler 对象:

my $*SCHEDULER = ThreadPoolScheduler.new(max_threads => 32);

任何可以看到此版本 $*SCHEDULER 的线程代码现在将使用这个有 32 个可用线程的调度程序。