SemaphoreSlim的暂停是否违背了它自己的目的？ [英] Does SemaphoreSlim's timeout defeat its own purpose?

问题描述

semaphore的真正力量是：

限制可以访问资源或池的线程数 并发资源

这是可以理解和清楚的。

但我一直没有机会处理Wait的重载，它接受超时整数-这似乎允许多个线程进入临界区，尽管我已显式设置信号量，不允许一次超过一个线程：

private readonly SemaphoreSlim _mutex = new SemaphoreSlim(1);

private void Main()
{
    Task.Run(() => DelayAndIncrementAsync());
    Task.Run(() => DelayAndIncrementAsync());
}

private void DelayAndIncrementAsync()
{
    _mutex.Wait(2000);

    try
    {
        Console.WriteLine(0);
        Thread.Sleep(TimeSpan.FromSeconds(5));
        Console.WriteLine(1);
    }
    finally
    {
        _mutex.Release();
    }
}

第一个线程正在进入互斥区，打印"0"，等待5秒，同时2秒后，另一个线程也进入临界区？

问题

这不是在违背信号量的全部目的吗？

我将使用此超时的现实生活场景是什么，尤其是当基本规则是-

"信号量=限制可以访问资源的线程数 或并发资源池

推荐答案

您需要检查等待的返回值。基于超时的等待将尝试2秒以获取互斥体，然后返回。您需要检查返回值是否为真(即您拥有互斥体)。

编辑：还要记住，如果信号量可用，基于超时的等待将立即返回，因此您不能使用此技术来防止代码中的无限循环。

private readonly SemaphoreSlim _mutex = new SemaphoreSlim(1);
void Main()
{

    Task.Run(()=>DelayAndIncrementAsync());
    Task.Run(()=>DelayAndIncrementAsync());
}
public   void  DelayAndIncrementAsync()
{
    if (_mutex.Wait(2000))
    {
        try
        {
            Console.WriteLine(0);
            Thread.Sleep(TimeSpan.FromSeconds(5));
            Console.WriteLine(1);
        }    
        finally
        {
            _mutex.Release();
        }
    } else {
        //oh noes I don't have the mutex
    }
}

这篇关于SemaphoreSlim的暂停是否违背了它自己的目的？的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！