간헐적인 파일 액세스 오류를 방지하기 위해 SemaphoreSlim을 사용하여 비동기 잠금을 올바르게 구현하는 방법은 무엇입니까?

비동기 잠금으로 간헐적인 파일 액세스 오류 해결

최근 ImageProcessor 라이브러리에서 결함이 있는 비동기 잠금으로 인해 캐시 업데이트 중에 간헐적인 파일 액세스 오류가 발생했습니다. 이 기사에서는 원래의 잘못된 구현을 분석하고 강력한 솔루션을 제공합니다.

원래 접근 방식에서는 해시된 URL을 비동기 잠금용 키로 사용하여 SemaphoreSlim 인스턴스를 ConcurrentDictionary에 저장하여 단일 키 잠금을 보장했습니다. 심각한 결함은 세마포어를 해제하기 SemaphoreSlim전에 사전에서 을 동기식으로 제거하는 데 있었습니다. 이 경쟁 조건으로 인해 파일 액세스 충돌이 발생했습니다.

다음 코드 조각은 문제가 있는 키/SemaphoreSlim 참조를 보여줍니다.

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

아래는 동시성 문제를 해결한 수정된 AsyncDuplicateLock 클래스입니다.

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();
        }
    }
}

이 개정된 구현을 통해 사전에서 제거되기 전에 세마포어가 해제되어 경쟁 조건이 제거되고 간헐적인 파일 액세스 오류가 해결됩니다.

위 내용은 간헐적인 파일 액세스 오류를 방지하기 위해 SemaphoreSlim을 사용하여 비동기 잠금을 올바르게 구현하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!