Lines Matching refs:taskPool

48     import std.parallelism : taskPool;
74     immutable pi = 4.0 * taskPool.reduce!"a + b"(n.iota.map!getTerm);
3294 @property TaskPool taskPool() @trusted  in taskPool()  function
3349     return taskPool.parallel(range);
3355     return taskPool.parallel(range, workUnitSize);
4011     taskPool.put(t3);
4024         taskPool.put(t);  in testSafe()
4028         taskPool.put(st);  in testSafe()
4168     assert(taskPool.size == totalCPUs - 1);
4234         auto asyncReader = taskPool.asyncBuf(&next, &file.eof);
4278     taskPool.put(myTask);
4291         assert(taskPool.workerIndex == 0);
4616     auto result = taskPool.amap!__genPair_12733(data);