4195     private __gshared TaskPool poolInstance;  in version()  local
4214     poolInstance = new TaskPool(2);
4215     scope(exit) poolInstance.stop();
4220     auto oldPriority = poolInstance.priority;
4221     poolInstance.priority = Thread.PRIORITY_MAX;
4222     assert(poolInstance.priority == Thread.PRIORITY_MAX);
4224     poolInstance.priority = Thread.PRIORITY_MIN;
4225     assert(poolInstance.priority == Thread.PRIORITY_MIN);
4227     poolInstance.priority = oldPriority;
4228     assert(poolInstance.priority == oldPriority);
4239     poolInstance.put(t);
4244     poolInstance.put(t2);
4250     poolInstance.put(st);
4255     poolInstance.put(st2);
4299     foreach (i, ref elem; poolInstance.parallel(arr))
4319     poolInstance.put(addTask);
4320     poolInstance.put(addScopedTask);
4327     foreach (i, elem; poolInstance.parallel(range))
4335     foreach (i, ref elem; poolInstance.parallel(logs))
4345     assert(poolInstance.amap!"a * a"([1,2,3,4,5]) == [1,4,9,16,25]);
4346     assert(poolInstance.amap!"a * a"([1,2,3,4,5], new long[5]) == [1,4,9,16,25]);
4347     assert(poolInstance.amap!("a * a", "-a")([1,2,3]) ==
4351     poolInstance.amap!("a * a", "-a")([1,2,3], tupleBuf);
4353     poolInstance.amap!("a * a", "-a")([1,2,3], 5, tupleBuf);
4359     poolInstance.amap!"a * 2"([1, 2, 3, 4, 5], ind);
4362     poolInstance.amap!"a / 2"(ind, ind);
4367     poolInstance.amap!"a * a"([1,2,3,4,5], buf);
4369     poolInstance.amap!"a * a"([1,2,3,4,5], 4, buf);
4372     assert(poolInstance.reduce!"a + b"([1]) == 1);
4373     assert(poolInstance.reduce!"a + b"([1,2,3,4]) == 10);
4374     assert(poolInstance.reduce!"a + b"(0.0, [1,2,3,4]) == 10);
4375     assert(poolInstance.reduce!"a + b"(0.0, [1,2,3,4], 1) == 10);
4376     assert(poolInstance.reduce!(min, max)([1,2,3,4]) == tuple(1, 4));
4377     assert(poolInstance.reduce!("a + b", "a * b")(tuple(0, 1), [1,2,3,4]) ==
4381     assert(poolInstance.reduce!"a + b"(0, iota(1000)) == serialAns);
4382     assert(poolInstance.reduce!"a + b"(iota(1000)) == serialAns);
4385     auto wl = poolInstance.workerLocalStorage(0);
4386     foreach (i; poolInstance.parallel(iota(1000), 1))
4392     auto parallelSum = poolInstance.reduce!"a + b"(wlRange);
4440                poolInstance.map!"a * a"(iota(3_000_001), 10_000),
4447                poolInstance.map!"a * a"(
4455                        poolInstance.map!"a * a"(iota(300_001), 10_000)
4464                poolInstance.asyncBuf(filter!"a == a"(iota(1_000_002)))
4511     auto abuf = poolInstance.asyncBuf(iota(-1.0, 3_000_000), 100);
4512     auto temp = poolInstance.map!sqrt(
4515     auto lmchain = poolInstance.map!"a * a"(temp, 100, 5);
4529     abuf = poolInstance.asyncBuf(iota(-1.0, 1_000_000), 100);
4548         assert(poolInstance.workerIndex == 0);
4551     foreach (i; poolInstance.parallel(iota(1000), 1))
4573         poolInstance.reduce!reduceException(iota(3))
4582         poolInstance.amap!mapException(iota(3))
4587         auto m = poolInstance.map!mapException(iota(3));  in mapThrow()
4606     assertThrown!Exception(poolInstance.asyncBuf(ThrowingRange.init));
4626             poolInstance = new TaskPool(poolSize);  in version()
4630             foreach (i; poolInstance.parallel( iota(0, numbers.length)) )  in version()
4645             foreach (num; poolInstance.parallel(myNumbers))  in version()
4651             uint[] squares = poolInstance.amap!"a * a"(numbers, 100);  in version()
4660             poolInstance.put(sumFuture);  in version()
4671             auto mySumParallel = poolInstance.reduce!"a + b"(numbers);  in version()
4679             poolInstance.put(myTask);  in version()
4684             foreach (i, letter; poolInstance.parallel(nestedOuter, 1))  in version()
4686                 foreach (j, number; poolInstance.parallel(nestedInner, 1))  in version()
4692             poolInstance.stop();  in version()
4715             poolInstance = new TaskPool(poolSize);  in version()
4718             stderr.writeln("Creator Raw Index:  ", poolInstance.threadIndex);  in version()
4719             assert(poolInstance.workerIndex() == 0);  in version()
4722             auto workerLocalStorage = poolInstance.workerLocalStorage!uint(1);  in version()
4723             foreach (i; poolInstance.parallel(iota(0U, 1_000_000)))  in version()
4728             1_000_000 + poolInstance.size + 1);  in version()
4734             foreach (thread; poolInstance.pool)  in version()
4740             foreach (i; poolInstance.parallel( iota(0, 1_000_000), 100 ))  in version()
4755             foreach (i; poolInstance.parallel( iota(0, matrix.length) ))  in version()
4757                 foreach (j; poolInstance.parallel( iota(0, matrix[0].length) ))  in version()
4771                 return poolInstance.amap!mySqrt(nums);  in version()
4774             real[][] sqrtMatrix = poolInstance.amap!parallelSqrt(matrix);  in version()
4791             poolInstance.put(saySuccess);  in version()
4799                 return poolInstance.reduce!"a + b"(input);  in version()
4802             auto sumSqrt = poolInstance.reduce!"a + b"(  in version()
4803                                poolInstance.amap!parallelSum(  in version()
4814             poolInstance.put(nanTask);  in version()
4817             if (poolInstance.size > 0)  in version()
4832                     poolInstance.put(uselessTask);  in version()
4862             foreach (ref elem; poolInstance.parallel(refRange))  in version()
4869             poolInstance.stop();  in version()