runasync 中的状态管理器并行事务

Question

在服务结构有状态服务中，有 RunAsync(cancellationToken) 和 using() 用于状态管理器事务。

我要重构的遗留代码包含两个队列，在 while(true) 内尝试出队，延迟时间为 1 秒。我想摆脱这种不必要的延迟，而是使用两个不同的反应队列（具有可靠队列的信号量）。

问题是，现在需要将依赖于这两个队列的两个不同的工作流分成两个单独的线程，因为如果这两个队列在单个线程中运行，一个 wait() 将阻止其他代码运行。 （我知道最好的做法可能是将这两个任务分成两个微服务，下一个项目。）

我想出了以下代码作为解决方案：

    protected override async Task RunAsync(CancellationToken cancellationToken)
    {
        await Task.WhenAll(AsyncTask1(cancellationToken), AsyncTask2(cancellationToken)).ConfigureAwait(false);
    }

每个任务都包含以下内容：

    while (true)
    {
        cancellationToken.ThrowIfCancellationRequested();

        using (var tx = this.StateManager.CreateTransaction())
        {
            var maybeMessage = await messageQueue.TryDequeueAsync(tx, cancellationToken).ConfigureAwait(false);

            if (maybeMessage.HasValue)
            {
                DoWork();
            }

            await tx.CommitAsync().ConfigureAwait(false);
        }
    }

似乎有效，但我只想确定 using(statemanger.createTansaction()) 是否可以以这种并行方式使用..

Answer 1

根据documentation

根据单项操作的副本角色（如TryDequeueAsync），ITransaction 使用可重复读取隔离级别（当primary时）或快照隔离级别（当**次要时）。

---

可重复阅读

默认情况下，任何可重复读取操作都采用共享锁。

快照

使用快照隔离完成的任何读取操作都是无锁的。

---

所以如果DoWork 不修改可靠集合，那么多个事务可以并行执行而没有问题。

在多次读取/更新的情况下 - 这可能会导致死锁，应小心操作。