Привет всем!
Задача следующая: имею массив - Task<BigInteger>[Environment.ProcessorCount] нужно перемножить все результаты.
На данный момент это решается так:
1.
2.
3.
4.
5.
6.
return Task.WhenAll(tasks).ContinueWith(_ =>
tasks
.Select(t => t.Result)
.AsParallel()
.Aggregate((a, b) => a * b),
TaskContinuationOptions.ExecuteSynchronously).Result;
Однако очевидно, что это не оптимальное решение, тк при получение первых двух результатов уже можно начать считать, не дожидаясь остальных. Так же очевидно(хотя проверил), если имеем планировщик в к-ом
BigInteger Result { get; private set; } +
lock (_lock){ Result *= task.Result; } это ещё медленнее(точнее практически столько же, как и без AsParallel()), чем выше.
Заранее благодарю ВС
