Parallel.invoke 取消令牌

发布于 2024-11-17 01:04:22 字数 1014 浏览 2 评论 0原文

使用 Parallel.Invoke 时，您可以传入包含 cancelationToken 的 ParallelOptions。是否可以在调用中使用该令牌来确定是否应该退出？是否应该在操作中使用对 CancellationTokenSource 的引用？

CancellationTokenSource cts = new CancellationTokenSource();
ParallelOptions po = new ParallelOptions();
po.CancellationToken = cts.Token;

Parallel.Invoke(po,
        new Action(() => { if (cts.IsCancellationRequested) return; Console.WriteLine("Invoked Method 1"); }),
        new Action(() => { if (cts.IsCancellationRequested) return; Console.WriteLine("Invoked Method 2"); }),
        new Action(() => { if (cts.IsCancellationRequested) return; Console.WriteLine("Invoked Method 3"); cts.Cancel(); }),
        new Action(() => { if (cts.IsCancellationRequested) return; Console.WriteLine("Invoked Method 4"); }),
        new Action(() => { if (cts.IsCancellationRequested) return; Console.WriteLine("Invoked Method 5"); })
    );

更新：取消发生得太晚了。我是在调用的方法之外执行此操作的。

注意：如果取消发生得足够快，Parallel.Invoke 将抛出异常，否则 inoked 方法将毫无失败地退出。

原文

When using Parallel.Invoke, you're able to pass in ParallelOptions which includes a cancelationToken. Is it possible to use that token in the invocations to determine if exiting should occur? Should a reference to the CancellationTokenSource be used from within the actions?

CancellationTokenSource cts = new CancellationTokenSource();
ParallelOptions po = new ParallelOptions();
po.CancellationToken = cts.Token;

Parallel.Invoke(po,
        new Action(() => { if (cts.IsCancellationRequested) return; Console.WriteLine("Invoked Method 1"); }),
        new Action(() => { if (cts.IsCancellationRequested) return; Console.WriteLine("Invoked Method 2"); }),
        new Action(() => { if (cts.IsCancellationRequested) return; Console.WriteLine("Invoked Method 3"); cts.Cancel(); }),
        new Action(() => { if (cts.IsCancellationRequested) return; Console.WriteLine("Invoked Method 4"); }),
        new Action(() => { if (cts.IsCancellationRequested) return; Console.WriteLine("Invoked Method 5"); })
    );

Update: The cancellation was happening too late. I was doing it outside of the invoked methods.

Note: If the cancellation happens soon enough, the Parallel.Invoke will throw, but otherwise the inoked methods will exit without fail.

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

煮茶煮酒煮时光 2024-11-24 01:04:22

是的。例如：

CancellationToken ct = tokenSource.Token;

ParallelOptions po = new ParallelOptions { CancellationToken = ct; };

Parallel.Invoke(po
    () => { Console.WriteLine(ct.IsCancellationRequested); },
    // etc
);

特别是，您可以将取消标记传递到其他方法中，这些方法可能会将其传播到异步任务。

Yes. For example:

CancellationToken ct = tokenSource.Token;

ParallelOptions po = new ParallelOptions { CancellationToken = ct; };

Parallel.Invoke(po
    () => { Console.WriteLine(ct.IsCancellationRequested); },
    // etc
);

In particular, you could pass the cancellation token into other methods which may propagate it to asynchronous tasks.

回复收藏 0 原文