TA貢獻(xiàn)1789條經(jīng)驗(yàn) 獲得超8個(gè)贊
SemaphoreSlim maxThread = new SemaphoreSlim(10);
for (int i = 0; i < 115; i++)
{
maxThread.Wait();
Task.Factory.StartNew(() =>
{
//Your Works
}
, TaskCreationOptions.LongRunning)
.ContinueWith( (task) => maxThread.Release() );
}
TA貢獻(xiàn)1802條經(jīng)驗(yàn) 獲得超5個(gè)贊
TPL Dataflow非常適合執(zhí)行此類操作。您可以輕松創(chuàng)建100％異步版本Parallel.Invoke：
async Task ProcessTenAtOnce<T>(IEnumerable<T> items, Func<T, Task> func)
{
ExecutionDataflowBlockOptions edfbo = new ExecutionDataflowBlockOptions
{
MaxDegreeOfParallelism = 10
};
ActionBlock<T> ab = new ActionBlock<T>(func, edfbo);
foreach (T item in items)
{
await ab.SendAsync(item);
}
ab.Complete();
await ab.Completion;
}
TA貢獻(xiàn)1862條經(jīng)驗(yàn) 獲得超6個(gè)贊
您有幾種選擇。您可以使用Parallel.Invoke入門：
public void DoWork(IEnumerable<Action> actions)
{
Parallel.Invoke(new ParallelOptions() { MaxDegreeOfParallelism = 10 }
, actions.ToArray());
}
這是一個(gè)替代選項(xiàng)，它將很難工作以恰好運(yùn)行10個(gè)任務(wù)（盡管處理這些任務(wù)的線程池中的線程數(shù)可能不同），并Task在完成時(shí)返回指示，而不是直到完成才阻塞。
public Task DoWork(IList<Action> actions)
{
List<Task> tasks = new List<Task>();
int numWorkers = 10;
int batchSize = (int)Math.Ceiling(actions.Count / (double)numWorkers);
foreach (var batch in actions.Batch(actions.Count / 10))
{
tasks.Add(Task.Factory.StartNew(() =>
{
foreach (var action in batch)
{
action();
}
}));
}
return Task.WhenAll(tasks);
}
如果您沒有MoreLinq，則此Batch功能是我更簡(jiǎn)單的實(shí)現(xiàn)：
public static IEnumerable<IEnumerable<T>> Batch<T>(this IEnumerable<T> source, int batchSize)
{
List<T> buffer = new List<T>(batchSize);
foreach (T item in source)
{
buffer.Add(item);
if (buffer.Count >= batchSize)
{
yield return buffer;
buffer = new List<T>();
}
}
if (buffer.Count >= 0)
{
yield return buffer;
}
}
舉報(bào)