Lines Matching refs:taskPool

57     import std.parallelism : taskPool;
83     immutable pi = 4.0 * taskPool.reduce!"a + b"(n.iota.map!getTerm);
2979         auto x = taskPool.fold!"a + b"([1, 2, 3, 4]);
2984         auto y = taskPool.fold!("a + b", "a * b")([1, 2, 3, 4], 0, 1);
2989         auto z = taskPool.fold!"a + b"([1, 2, 3, 4], 0, 20);
3536     assert(taskPool.fold!"a + b"(r) == expected);
3539     assert(taskPool.fold!"a + b"(r, 0) == expected);
3540     assert(taskPool.fold!("a + b", "a + b")(r, 0, 0) == tuple(expected, expected));
3543     assert(taskPool.fold!"a + b"(r, 0, 42) == expected);
3544     assert(taskPool.fold!("a + b", "a + b")(r, 0, 0, 42) == tuple(expected, expected));
3559     auto mySum = taskPool.reduce!"a + b"(MyIota());
3569 @property TaskPool taskPool() @trusted  in taskPool()  function
3621     return taskPool.parallel(range);
3627     return taskPool.parallel(range, workUnitSize);
4273     taskPool.put(t3);
4286         taskPool.put(t);  in testSafe()
4290         taskPool.put(st);  in testSafe()
4430     assert(taskPool.size == totalCPUs - 1);
4496         auto asyncReader = taskPool.asyncBuf(&next, &file.eof);
4540     taskPool.put(myTask);
4553         assert(taskPool.workerIndex == 0);
4888     auto result = taskPool.amap!__genPair_12733(data);