如何解決非同步鎖定間歇性檔案存取錯誤？

基於鍵的非同步鎖定

本文討論了 ImageProcessor 庫中遇到的一個問題：在新增快取期間發生檔案存取間歇性錯誤。錯誤訊息表示相關文件正在被另一個程序使用。為了解決這個問題，實作了一種基於鍵的非同步鎖定機制。然而，後來發現該實現有疏忽。

問題所在

最初的鎖定類別 AsyncDuplicateLock 試圖透過使用鍵從並發字典中檢索訊號量來執行非同步鎖定。但是，它在釋放信號量之前錯誤地將其從字典中刪除。這意味著信號量在仍在使用時被刪除，導致觀察到的文件存取錯誤。

解

為了解決這個問題，修改了鎖定類別。更新後的版本沒有使用基於並發字典的無鎖方法，而是使用更傳統的方法，結合引用計數和單一鎖定。這確保了只有在信號量不再使用時才釋放它們。

以下是修改後的鎖定類別代碼：

<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>

此更新後的實作為每個信號量維護一個引用計數，並確保只有在不再有活動鎖定引用信號量時才將其從字典中刪除。這種方法有效地解決了先前實作中遇到的文件存取間歇性錯誤。

以上是如何解決非同步鎖定間歇性檔案存取錯誤？的詳細內容。更多資訊請關注PHP中文網其他相關文章！