zoukankan
html css js c++ java
C#线程 在某一时间内,只有N个线程在并发执行,其余都在队列中的实现
具体的需求是 在某一时间点,只有N个线程在并发执行,如果有多余的线程,则排队等候
~
还真是费尽心思啊
~
最终还是被我攻克了
~
下面我就来说说具体的实现
C#提供了Mutex与Interlocked这两个与线程相关的类,都在Threading命名空间下
~!
Mutex中提供了WiteOne,ReleaseMutex 两个实例方法
~
WiteOne的作用是
"
阻塞当前线程,提供对该线程的原子操作
"
也就是说当一个线程遇到WiteOne的时候,如果在WiteOne里面没有线程在操作,则此线程进去操作
而里面有线程的时候,所有到此的线程均需要排队等候里面的线程执行完毕
~
而控制这样操作的结束标记就是使用ReleaseMutex 方法
!
就好比WiteOne是一把锁一样
~
而ReleaseMutex 就是一把钥匙
当10个人都看到这个门的时候,第一个到达门口的人会看到屋子里没有人,则他进去,同时会把门锁上
~
后面的人自然要在门口等候,当此人在屋子里执行完任务后他会用钥匙把门打开
!
出去后把锁交给门口排队的第二位同志,第二位同志再做同样的操作
如果第一位同志执行完任务以后不把使用权交给第二个人的话,而直接退出
那么屋子自然就空了下来,而门还是锁的
~
不必担心
~
门会自动打开,只要是前一个人已经不在屋子里即可
~
然后再来说说这个Interlocked,官方说明是
"
对一个变量进行原子操作进行递增或者递减然后保存
"
原子操作的概念就是,有且只有一个线程在对此变量进行操作
~
不准其他线程干预的操作
当对一个变量进行原子操作的时候,此变量就会加锁,而其他线程是无法访问的,只能挂起等候此变量解锁
我感觉实际上使用的也就是Mutex来实现的
好了开始说说具体的实现吧
public
class
MutexTest
{
private
static
int
poolFlag
=
0
;
//
标记
private
const
int
amountThread
=
10
;
//
线程总量
private
const
int
maxThread
=
3
;
//
可执行线程最大数量
private
static
Mutex muxConsole
=
new
Mutex() ;
public
static
void
Main()
{
for
(
int
i
=
0
; i
<
amountThread ; i
++
)
{
//
创建指定数量的线程
//
是线程调用Run方法
//
启动线程
Thread trd
=
new
Thread(
new
ThreadStart( Run ) ) ;
trd.Name
=
"
线程
"
+
i ;
trd.Start() ;
}
}
public
static
void
Run()
{
muxConsole.WaitOne();
//
阻塞队列
Interlocked.Increment(
ref
poolFlag) ;
//
标记+1
if
(poolFlag
!=
maxThread)
//
判断是否等于上限
muxConsole.ReleaseMutex();
//
如果此线程达不到可执行线程上限,则继续开通,让后面的线程进来
Console.WriteLine(
"
{0} 正在运行
\n
"
, Thread.CurrentThread.Name ) ;
Thread.Sleep(
5000
);
//
模拟执行
Console.WriteLine(
"
{0} 已经中止
\n
"
, Thread.CurrentThread.Name ) ;
//
标记-1
Interlocked.Decrement(
ref
poolFlag) ;
}
}
注释很全,大家慢慢看吧
~
我准备把这个用到WebService的负载平衡上面
~
这样我就可以自己控制请求的数量了
~
查看全文
相关阅读:
ping 网关不同的原因(51cto博客搬迁)
Linux Shell常用命令总结(51cto 博客搬迁)
学生管理系统管理系统
offset属性在各版本浏览器中的不同算法
常用正则表达式
select城市3级联动
html5表单验证消息框
清除浏览器默认选择效果
排序之简单的冒泡排序
简单的桶排序
原文地址:https://www.cnblogs.com/kokoliu/p/520434.html
最新文章
使用JSON进行数据传输的总结
Spring Web MVC是什么
JAVA面试总结
maven
JAVA一些基础概念
jQuery Validate验证框架详解
JAVA环境变量配置
SpringMVC拦截器-性能监控
asp.net ImageButton鼠标事件更换图片
ASP.NET 操作json
热门文章
『脉脉体验』
DatagramPacket与DatagramSocket
多线程实现端口扫描
局域网活跃主机扫描
java 实现数组去重(集合转换)
netbeans 下 第三方库的导入问题
初学 Java Web 开发,请远离各种框架,从 Servlet 开发
博客搬迁
ubuntu13.04下ftp的简单搭建过程
Cisco Packet Tracer 使用方法(51cto博客搬迁)
Copyright © 2011-2022 走看看