首頁 >後端開發 >C++ >如何在 C# 中使用非同步鎖定避免間歇性檔案存取錯誤?

如何在 C# 中使用非同步鎖定避免間歇性檔案存取錯誤?

Patricia Arquette
Patricia Arquette原創
2025-01-15 06:03:44814瀏覽

How to Avoid Intermittent File Access Errors with Asynchronous Locking in 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中文網其他相關文章!

陳述:
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn