Does SemaphoreSlim#39;s timeout defeat its own purpose?(SemaphoreSlim的暂停是否违背了它自己的目的?)
本文介绍了SemaphoreSlim的暂停是否违背了它自己的目的?的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!
问题描述
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的暂停是否违背了它自己的目的?的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持编程学习网!
沃梦达教程
本文标题为:SemaphoreSlim的暂停是否违背了它自己的目的?


猜你喜欢
- 在哪里可以找到使用中的C#/XML文档注释的好例子? 2022-01-01
- C#MongoDB使用Builders查找派生对象 2022-09-04
- 如何用自己压缩一个 IEnumerable 2022-01-01
- 带有服务/守护程序应用程序的 Microsoft Graph CSharp SDK 和 OneDrive for Business - 配额方面返回 null 2022-01-01
- WebMatrix WebSecurity PasswordSalt 2022-01-01
- 输入按键事件处理程序 2022-01-01
- Web Api 中的 Swagger .netcore 3.1,使用 swagger UI 设置日期时间格式 2022-01-01
- MoreLinq maxBy vs LINQ max + where 2022-01-01
- C# 中多线程网络服务器的模式 2022-01-01
- 良好实践:如何重用 .csproj 和 .sln 文件来为 CI 创建 2022-01-01