原文
import std.stdio;
import std.parallelism;
import std.conv;
enum I = 1_000;
enum J = 1_000;
void main() {
auto results = new int[I * J];
//如果想要新的任务池:
// auto tp = new TaskPool(totalCPUs);
//(并在下面使用tp.而不是taskPool.)
foreach (i; 0 .. I) {
foreach (j; 0 .. J) {
taskPool.put(task!foo(i, j, results));
}
}
//警告:我不确定是否可以相信结果是否准备好.(?)
//parallel()确实在每个任务上调用了yieldForce(),但对`put`进池中的任务,似乎没有该选项.
enum toPrint = 10;
writeln(results[0..toPrint]);
writeln("[...]");
writeln(results[$-toPrint..$]);
}
void foo(size_t i, size_t j, int[] results) {
results[i * J + j] = to!int(i * J + j);
}