|
|
@ -128,6 +128,16 @@ namespace MathNet.Numerics.Threading |
|
|
var tasks = new Task<T>[ThreadQueue.ThreadCount]; |
|
|
var tasks = new Task<T>[ThreadQueue.ThreadCount]; |
|
|
var size = count / tasks.Length; |
|
|
var size = count / tasks.Length; |
|
|
|
|
|
|
|
|
|
|
|
if (count <= 1) |
|
|
|
|
|
{ |
|
|
|
|
|
// if (count == 1)
|
|
|
|
|
|
// {
|
|
|
|
|
|
// body(fromInclusive);
|
|
|
|
|
|
// }
|
|
|
|
|
|
|
|
|
|
|
|
// return;
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
var intial = localInit(); |
|
|
var intial = localInit(); |
|
|
|
|
|
|
|
|
// partition the jobs into separate sets for each but the last worked thread
|
|
|
// partition the jobs into separate sets for each but the last worked thread
|
|
|
|