25 lines
489 B
C#
25 lines
489 B
C#
|
namespace StevesBot.Worker.Threading;
|
||
|
|
|
||
|
|
internal sealed class AsyncLock : IAsyncLock
|
||
|
|
{
|
||
|
|
private readonly SemaphoreSlim _semaphore = new(1, 1);
|
||
|
|
private bool _disposed;
|
||
|
|
|
||
|
|
public async Task<IDisposable> LockAsync(CancellationToken cancellationToken = default)
|
||
|
|
{
|
||
|
|
await _semaphore.WaitAsync(cancellationToken);
|
||
|
|
return new LockReleaser(_semaphore);
|
||
|
|
}
|
||
|
|
|
||
|
|
public void Dispose()
|
||
|
|
{
|
||
|
|
if (_disposed)
|
||
|
|
{
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
|
||
|
|
_semaphore.Dispose();
|
||
|
|
_disposed = true;
|
||
|
|
}
|
||
|
|
}
|