У меня есть пул задач, которые необходимо обработать в течение периода времени, пока токен отмены не будет отменен.
Выполнение не должно длиться дольше определенного времени, в противном случае его необходимо отменить. К сожалению, я заметил, что установленное время задержки не соблюдается.
Вот фрагмент кода:
Код: Выделить всё
private async Task DoStart(bool isMonitor)
{
try
{
var changeState = true;
_socketTokenSource.Token.ThrowIfCancellationRequested();
while (!_socketTokenSource.Token.IsCancellationRequested)
{
await DoStartIntern(isMonitor);
changeState = false;
}
}
catch
{
}
finally
{
_socketTokenSource.Dispose();
_socketTokenSource = new CancellationTokenSource();
}
}
private async Task DoStartIntern(bool isMonitor)
{
using var timeoutDataTokenSource = new CancellationTokenSource();
Task runTask = Task.Run(async () =>
{
await DoProduceData(timeoutDataTokenSource.Token);
var statusTask = !isMonitor
? DoProduceStatusData(timeoutDataTokenSource.Token)
: DoProduceRemainingData(timeoutDataTokenSource.Token);
await statusTask;
}, timeoutDataTokenSource.Token);
try
{
_unixTimeInMsec = ((DateTimeOffset)DateTime.UtcNow).ToUnixTimeMilliseconds();
if (isMonitor)
timeoutDataTokenSource.CancelAfter(200);
await runTask;
}
catch(OperationCanceledException ex)
{
if (ex.CancellationToken != timeoutDataTokenSource.Token)
throw new OperationCanceledException();
}
}
}
Подробнее здесь: https://stackoverflow.com/questions/798 ... od-of-time
Мобильная версия