Я бы сделал как-то так:
using (var cts = new CancellationTokenSource())
{
var ct = cts.Token;
tasks =
Enumerable.Range(0, 300)
.Select(i => Task.Run(() => MyTask(ct), ct));
cts.CancelAfter(TimeSpan.FromSeconds(30));
try
{
await Task.WhenAll(tasks);
}
catch (AggregateException)
{
}
}
Если нужно игнорировать отмену, то используйте
async Task IgnoreCancellation(Task t)
{
try
{
await t;
}
catch (OperationCancelledException)
{
}
}
и пишите IgnoreCancellation(Task.Run(...))
.
Дополнение: Как правильно заметил @Alexander Petrov, у вас CancellationToken
не передаётся в MyTask
. Это неправильно. Task
'и и async
/await
реализуют по сути разновидность кооперативной многозадачности: каждое задание должно сотрудничать, и само управлять выполнением. Таким образом, вы должны передавать токен вовнутрь, и MyTask
обязан проверять токен время от времени, и обрываться, если его об этом попросят, самостоятельно. Остановить запущенный Task
невозможно, можно лишь попросить его остановиться самостоятельно.
Для вашего случая, это может выглядеть, например, так:
void MyTask(CancellationToken ct)
{
foreach (var x in data)
{
ct.ThrowIfCancellationRequested();
// обработать элемент данных x.
}
}
Или если MyTask
работает асинхронно, например, так:
async Task MyTask(CancellationToken ct)
{
foreach (var x in data)
{
ct.ThrowIfCancellationRequested();
await InternalProcessing(x, ct); // обязательно передать токен дальше!
}
}
CancellationTokenSource
?