如何在 C# 中使用异步锁定避免间歇性文件访问错误？

在 C# 中使用异步锁定解决间歇性文件访问错误

异步锁定，特别是在使用哈希 URL 和类似 AsyncDuplicateLock 的类时，有时会导致间歇性文件访问错误。 这通常源于并发字典中信号量处理不当。 最初有缺陷的方法可能如下所示：

<code class="language-csharp">SemaphoreSlim locker;
if (SemaphoreSlims.TryRemove(s, out locker))
{
    locker.Release();
    locker.Dispose();
}</code>

这里的问题是在释放信号量之前删除它。这会造成过多的信号量流失，导致即使从字典中删除信号量后仍会持续使用信号量。

强大的解决方案采用引用计数来管理信号量生命周期：

<code class="language-csharp">public sealed class AsyncDuplicateLock
{
    private sealed class RefCounted<T>
    {
        public RefCounted(T value)
        {
            RefCount = 1;
            Value = value;
        }

        public int RefCount { get; set; }
        public T Value { get; private set; }
    }

    private static readonly Dictionary<object, RefCounted<SemaphoreSlim>> SemaphoreSlims
                        = new Dictionary<object, RefCounted<SemaphoreSlim>>();

    private SemaphoreSlim GetOrCreate(object key)
    {
        RefCounted<SemaphoreSlim> item;
        lock (SemaphoreSlims)
        {
            if (SemaphoreSlims.TryGetValue(key, out item))
            {
                ++item.RefCount;
            }
            else
            {
                item = new RefCounted<SemaphoreSlim>(new SemaphoreSlim(1, 1));
                SemaphoreSlims[key] = item;
            }
        }
        return item.Value;
    }

    public IDisposable Lock(object key)
    {
        GetOrCreate(key).Wait();
        return new Releaser { Key = key };
    }

    public async Task<IDisposable> LockAsync(object key)
    {
        await GetOrCreate(key).WaitAsync().ConfigureAwait(false);
        return new Releaser { Key = key };
    }

    private sealed class Releaser : IDisposable
    {
        public object Key { get; set; }

        public void Dispose()
        {
            RefCounted<SemaphoreSlim> item;
            lock (SemaphoreSlims)
            {
                item = SemaphoreSlims[Key];
                --item.RefCount;
                if (item.RefCount == 0)
                    SemaphoreSlims.Remove(Key);
            }
            item.Value.Release();
        }
    }
}</code>

此修订后的代码使用 RefCounted<T> 包装器来跟踪信号量引用。 信号量只有在引用计数为零时才会从字典中删除，确保正确释放并防止过早处置，从而消除间歇性文件访问错误。

以上是如何在 C# 中使用异步锁定避免间歇性文件访问错误？的详细内容。更多信息请关注PHP中文网其他相关文章！