在等待挂起操作取消时处理 SemaphoreSlim 是否安全？

如何解决在等待挂起操作取消时处理 SemaphoreSlim 是否安全？

我不得不使用 SemaphoreSlim 来确保对我的代码的某些部分进行单线程访问，并希望确保我正确处理了所有内容。假设我有以下课程：

public class Foo
{
    private readonly CancellationTokenSource _canceller = new CancellationTokenSource();
    private readonly SemaphoreSlim _semaphore = new SemaphoreSlim(1);

    ~Foo()
    {
        dispose(false);
        GC.SuppressFinalize(this);
    }

    public void dispose()
    {
        dispose(true);
    }

    protected void dispose(bool disposing)
    {
        if (_disposed)
            return;

        _canceller.Cancel();

        if (_disposing)
            _semaphore.dispose();

        _disposed = true;
    }

    public async Task ExecuteAsync()
    {
        try
        {
            await _semaphore.WaitAsync(_canceller.Token);
        }
        catch (OperationCanceledException)
        {
            throw new ObjectdisposedException(nameof(Foo),"Cannot execute on a Foo after it has been disposed");
        }
        
        try
        {
            // Critical section
        }
        finally
        {
            _semaphore.Release();
        }
    }
}

当我调用 dispose(true) 时，我有效地逐行执行以下几行：

_canceller.Cancel();
_semaphore.dispose();

我的问题是，当前正在等待临界区的任何其他线程/任务会发生什么？我能保证他们总是先看到取消，这样信号量就不会被处理了吗？到目前为止，这还没有引起任何问题，但这并不意味着它是安全的。

解决方法

documentation for SemaphoreSlim 似乎对您的问题非常具体。

SemaphoreSlim 的所有公共成员和受保护成员都是线程安全的，可以从多个线程并发使用，但 Dispose() 除外，它必须仅在 SemaphoreSlim 上的所有其他操作都已完成时使用。

保证所有其他操作都已完成的唯一真正方法是确保所有任务都已完成，如文档中的示例所示。

public class Foo
{
    private readonly List<Task> _semaphoreTasks = new list<Task>();

    protected void Dispose(bool disposing)
    {
        if (_disposed)
            return;

        _canceller.Cancel();

        if (_disposing) 
        {
            Task.WaitAll(tasks);
            _semaphore.Dispose();
        }

        _disposed = true;
    }

    public async Task ExecuteAsync()
    {
        try
        {
            var task = _semaphore.WaitAsync(_canceller.Token);
            _semaphoreTasks.Add(task);
            await task;
        // ...

这也很可能需要确保在执行处理时将内容添加到列表中。（您可以将私有类变量设置为本地方法变量，然后将类变量设置为空）