博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
线程同步-使用SimaphoreSlim类
阅读量:5319 次
发布时间:2019-06-14

本文共 948 字,大约阅读时间需要 3 分钟。

SimaphoreSlim类是作为Semaphore类的轻量级版本的。该类限制了同时访问同一个资源的线程数量。

代码Demo:

using System;

using System.Threading;

在Main方法下面加入以下代码片段:

 static SemaphoreSlim _semaphore = new SemaphoreSlim(4);------1

static void AccessDatabase(string name, int seconds)

{
Console.WriteLine("{0} waits to access a database", name);
_semaphore.Wait();
Console.WriteLine("{0} was granted an access to a database", name);
Thread.Sleep(TimeSpan.FromSeconds(seconds));
Console.WriteLine("{0} is completed", name);
_semaphore.Release();
}

在Main方法中加入以下代码片段:

for (int i = 1; i <= 6; i++)

{
 string threadName = "Thread" + i;
 int secondsToWait = 2 + 2 * i;
 var t = new Thread(() => AccessDatabase(threadName, secondsToWait));
 t.Start();
}

工作原理:

主线程启动时,创建了SemaphoreSlim的一个实例,并在其构造函数中制定允许的并发线程数量(1行所示)。然后启动了6个不同名称和不同初始运动时间的线程。

每个线程都尝试获取数据库的访问,但是我们借助于信号系统限制了访问数据库的并发数为4个线程。当有4个线程获取了数据库的访问后,其它两个线程需要等待,知道之前线程中的某一个完成工作并调用_semaphore.Release方法来发出信号。

转载于:https://www.cnblogs.com/v-haoz/p/9260521.html

你可能感兴趣的文章
C# JSON字符串序列化与反序列化
查看>>
HTTPS、SPDY和HTTP/2的性能比较
查看>>
GRPC单向/双向流
查看>>
Ubuntu18.10下配置PHP7.2 + Apache2 + Mysql5.7
查看>>
Java变量类型,实例变量 与局部变量 静态变量
查看>>
Angular实践----理解数据绑定过程
查看>>
sublime快捷键
查看>>
mysql操作命令梳理(4)-中文乱码问题
查看>>
Hyper-V Centos7 网络设置 虚拟机固定IP
查看>>
Python环境搭建(安装、验证与卸载)
查看>>
android菜鸟学习笔记5----第一个android程序
查看>>
2.5 非透明PCI桥 分类: 浅谈PCI 2...
查看>>
POJ 2263 Heavy Cargo(Floyd + map)
查看>>
Macbook pro 下修改MySQL数据库密码
查看>>
使用postman做接口测试(一)
查看>>
Linux的locale、LC_ALL和LANG
查看>>
C# 动态调用DLL库
查看>>
Ubuntu使用问题解决办法
查看>>
android 开发 实现RecyclerView的列表单选功能
查看>>
从零教你如何获取hadoop2.4源码并使用eclipse关联hadoop2.4源码
查看>>