在服务结构服务中存储取消令牌

Question

我正在尝试在服务结构有状态服务中实现取消任务功能。

计划正在使用取消令牌将通知传播到链接的线程/任务。

问题是，虽然有这些长时间运行的任务和线程在等待这个信号，但我不确定如何根据另一个 Web API 调用找到正确的取消令牌。

我正在考虑使用可靠的字典，然后甚至在尝试之前，我认为这会遇到死胡同，因为cancellationToken 无法序列化/反序列化。

请帮助我解决这个问题的好方法。

更新（我不想创建一个新线程丢失该线程中提到的一些重要上下文，所以在这篇文章中更新。）

确认下面的链接描述确实显示了可靠的服务和参与者方法可以支持取消令牌。然而，典型的用例是直接通过 Web API 接收取消请求，用户触发，例如点击刷新、转到另一个页面等。在这种情况下，完全相同的端点需要接收请求，而之前的 http 请求仍然存在一些长时间运行的任务或卡住。这不是这个线程中的场景。

来自链接：https://blogs.msdn.microsoft.com/azureservicefabric/2016/02/23/service-fabric-sdk-v1-5-175-and-the-adoption-of-virtual-machine-scale-sets/

对 IService/IActor 的 CancellationToken 支持

Reliable Service 和 Reliable Actor 方法现在支持可以通过 ActorProxy 和 ServiceProxy 远程访问的取消令牌，允许您实现协作取消。想要取消长时间运行的服务或参与者方法的客户端可以发出取消令牌的信号，并且取消意图将传播到参与者/服务方法。然后，该方法可以通过查看其取消令牌参数的状态来确定何时停止执行。

例如，一个参与者的合约可能有一个可能长时间运行的方法，可以如下建模：

        public interface IPrimeNumberActorInterface : IActor
        {

            Task<ulong> FindNextPrimeNumberAsync
                (ulong previous, CancellationToken cancellationToken);

        }

希望取消方法执行的客户端代码可以通过取消取消令牌来传达其意图。

Answer 1

CancellationToken 和 CancellationTokenSource 不可序列化，并且不会在 SF 中的服务调用或数据复制之间流动。它只能用于告诉同一进程中的处理程序一个操作已被取消，并且在收到响应时应该停止任何处理或忽略任何继续。

如果您希望能够在另一个服务中启动和取消操作，您应该将操作拆分为两个调用。

• 首先会生成一个Operation ID返回给客户端，并为此操作创建CancellationTokenSource生成CancellationToken传递给后台运行的Task\Thread
• 第二个将接收 OperationID 并识别 CancellationTokenSource 是否存在并取消它，以便提供给任何 Task\Thread 的令牌可以停止任何处理（如果尚未完成或取消）。

您可以简单地将其作为Dictionary<Guid, CancellationTokenSource> 存储在运行任务的进程\分区中。

如果您在 SF 的多个分区中运行这些任务，并计划将其存储在 Reliable Dictionary 中，这不是一个好主意，因为如前所述，您无法将取消序列化到其他分区。

在这种情况下，您可以存储 OperationID 和 PartitionID，因此所有分区都知道操作在哪里运行，当您在任何分区上收到取消调用时，服务将在这个可靠的字典中查找操作所在的位置运行并将取消转发到正确的分区。