0
点赞
收藏
分享

微信扫一扫

d并行两个循环


​​原文​​

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);
}


举报

相关推荐

0 条评论