如何使用 AsyncEx 检查另一个线程是否在锁定部分内？

Question

我刚刚开始使用Nito.AsyncEx 包和AsyncLock 而不是普通的lock() { ... } 部分，我在锁定部分中有async 调用（因为在这种情况下你不能使用lock() good reasons 我刚刚读到）。这是我从 Hangfire 运行的一项工作。我们称其为“工作线程”。

在另一个线程中，来自 ASP.NET 控制器，我想检查是否有一个线程当前正在锁定部分内执行。如果锁定部分中没有线程，那么我将通过 Hangfire 安排后台作业。如果锁定部分中已经有一个线程，那么我不想安排另一个线程。 （是的，这听起来可能有点奇怪，但那是另一回事了）。

有没有办法使用Nito.AsyncEx 对象来检查这一点，还是我应该在锁定部分的开头设置一个标志并在最后取消设置？

例如我想要这个：

public async Task DoAJobInTheBackground(string queueName, int someParam)
{ 
    // do other stuff...

    // Ensure I'm the only job in this section
    using (await _asyncLock.LockAsync())
    {           
        await _aService.CallSomethingAsync());           
    }

    // do other stuff...
}

并从控制器调用的服务中使用我想象的方法IsSomeoneInThereNow()：

public void ScheduleAJobUnlessOneIsRunning(string queueName, int someParam)
{ 

    if (!_asyncLock.IsSomeoneInThereNow())
    {
        _backgroundJobClient.Enqueue<MyJob>(x => 
            x.DoAJobInTheBackground(queueName, someParam));
    }

}

但到目前为止，我只能看到如何使用单独的变量来执行此操作（想象 _isAnybodyInHere 是 thread-safe bool 或者我改用了 Interlocked）：

public async Task DoAJobInTheBackground(string queueName, int someParam)
{ 
    // do other stuff...

    // Ensure I'm the only job in this section
    using (await _asyncLock.LockAsync())
    {
        try
        {
            _isAnybodyInHere = true; 
            await _aService.CallSomethingAsync());
        }
        finally
        {
            _isAnybodyInHere = false; 
        }
    }

    // do other stuff...
}

以及来自控制器调用的服务：

public void ScheduleAJobUnlessOneIsRunning(string queueName, int someParam)
{ 

    if (!_isAnybodyInHere)
    {
        _backgroundJobClient.Enqueue<MyJob>(x => 
            x.DoAJobInTheBackground(queueName, someParam));
    }

}

真的感觉应该有更好的方法。 AsyncLockdoc says：

您可以使用 already-cancelled CancellationToken 调用 Lock 或 LockAsync 尝试立即获取 AsyncLock 没有实际进入等待队列。

但我不明白该怎么做，至少使用同步 Lock 方法。

Answer 1

我不明白该怎么做

您可以创建一个新的CancellationToken 并传递true 来创建一个已经取消的：

using (_asyncLock.Lock(new CancellationToken(canceled: true)))
{
  ...
}

如果锁已被持有，对Lock 的调用将抛出。

也就是说，我认为这不是解决您问题的好方法。后台作业总是有可能即将完成，控制器检查锁并确定它已被持有，然后后台作业释放锁。在这种情况下，控制器不会触发后台作业。

Answer 2

您必须永远（！）对任何其他线程或进程做出任何假设！

在此特定示例中，您必须做的是“安排另一项工作”，除非您已经这样做了。 （为了避免“分叉炸弹”。） 然后，作业一旦开始执行，就必须决定：“我应该这样做吗？” 如果不是，作业悄悄地退出。

或者——也许这里的实际问题是：“已经有其他人了 ≤scheduled_this_job≥？”