使用WaitOne(100)与WaitOne(0) + Task.Delay(100)等待命名信号量

本文关键字:WaitOne 等待 信号量 Delay 使用 Task | 更新日期: 2023-09-27 18:18:35

我需要访问由两个进程共享的Windows 8.1应用程序中的资源:应用程序本身和后台任务,所以我需要一个命名的Semaphore, SemaphoreSlim不适用那里,因为我在获取和发布之间做异步工作,我不能使用Mutex

我已经在PCL中创建了一个类,它创建了信号量,并允许我以这种方式等待WaitOne方法:

public sealed class AsyncSemaphore:IDisposable
{
    Semaphore _semaphore;
    public AsyncSemaphore(int initialCount, int maximumCount, string name)
    {
        _semaphore = new Semaphore(initialCount, maximumCount, name);
    }
    public IAsyncOperation<bool> WaitOneAsync()
    {
        return AsyncInfo.Run<bool>(cancellationToken => 
            Task.Run(()=>{
                while (!_semaphore.WaitOne(100))
                {
                    Logger.Log("Waiting...");
                    cancellationToken.ThrowIfCancellationRequested();
                }
                return true;
            },cancellationToken));
    }
    public int Release()
    {
        return _semaphore.Release();
    }
    public void Dispose()
    {
        if (_semaphore != null)
        {
            _semaphore.Dispose();
            _semaphore = null;
        }
    }
}

但是WaitOneAsync也可以这样写:

public IAsyncOperation<bool> WaitOneAsync()
{
    return AsyncInfo.Run<bool>(async cancellationToken =>
        {
            while (!_semaphore.WaitOne(0))
            {
                Logger.Log("Waiting...");
                await Task.Delay(100, cancellationToken);
            }
            return true;
        });
}

然后我在我的代码中这样使用它:

_semaphore= new AsyncSemaphore(1,1,"uniquename");
//....
await _semaphore.WaitOneAsync();
try
{
   //do more async work
}
finally
{
   _semaphore.Release();
}

正确吗?哪一个是最好的,使用更少的资源?

使用WaitOne(100)与WaitOne(0) + Task.Delay(100)等待命名信号量

第一个选项在整个等待过程中保持线程,首先通过同步等待,然后通过繁忙等待(while循环)。第二个选项至少在某种程度上是异步的,因为它使用Task.Delay来等待,然后才诉诸于忙等待。

第二个(async)选项使用较少的资源,但需要等待整个超时(100ms)才能再次检查,而第一个(sync)选项可以在释放信号量时立即进入信号量。

async选项使用的资源比sync版本少,但实际同步速度比sync版本慢。所以这取决于你的具体需求,可扩展性还是速度。


您可以通过降低100ms的超时来进行优化,从而使async选项越来越接近同步版本。