在ServiceFabric的RunAsync()中模拟取消令牌请求

我试图使用FabricClient API来模拟正常的故障(如分区/副本/实例重新启动),但由于某些原因,服务一直在恢复。

它最终成功的唯一一次是当我从集群UI手动删除服务时,然后我看到它被卡住了,因为RunAsyc被卡住了。(我写了一个特殊的虚拟服务,它不接受取消令牌。)

foreach (var service in Services)
        {
            var partitions = FabricClient.QueryManager.GetPartitionListAsync(service.ServiceName).Result;
            foreach (var partition in partitions)
            {
                var operationGuid = Guid.NewGuid();
                restartOperationsIds.Add(operationGuid);
                var partitionId = partition.PartitionInformation.Id;

                FabricClient.FaultManager.RestartReplicaAsync(
                    ReplicaSelector.PrimaryOf(PartitionSelector.PartitionIdOf(service.ServiceName, partitionId)),
                    CompletionMode.Verify, CancellationToken.None);

                FabricClient.TestManager.StartPartitionRestartAsync(operationGuid,
                    PartitionSelector.PartitionIdOf(service.ServiceName, partitionId),
                    RestartPartitionMode.AllReplicasOrInstances, TimeSpan.FromMinutes(2));
            }
        }