utilizing var tokenSource = new CancellationTokenSource(10_000);
var token = tokenSource.Token;
await foreach (var knowledge in Job.WhenEach(duties).WithCancellation(token))
{
if (!tokenSource.TryReset())
token.ThrowIfCancellationRequested();
Console.WriteLine(await knowledge);
tokenSource.CancelAfter(10_000);
}
Within the previous code instance, CancellationTokenSource is used to create situations of a CancellationToken, which represents a cancellation token for use for cancellation of a process. The ThrowIfCancellationRquested methodology is named to throw an OperationCanceledException if cancellation has been requested. The CancelAfter methodology is used to schedule a cancel operation as soon as the required variety of milliseconds elapses.
Key takeaways
The Job.WhenEach is a brand new asynchronous static methodology launched in .NET 9 that addresses the constraints of the Job.WhenAll and Job.WhenAny strategies. By enabling the rapid processing of accomplished duties, it enhances the efficiency and scalability of your purposes significantly.
Observe that you should use ThrowIfCancellationRequested from inside a process solely. On this case, you’ll not need to deal with any exception explicitly. As an alternative, when this methodology is named on a token occasion, the execution leaves the presently operating process and the Job.IsCancelled property is ready to True.