知识大全 C#线程池的实现

Posted 2022-07-17 操作

篇首语：人生处万类,知识最为贤。本文由小常识网(cha138.com)小编为大家整理，主要介绍了知识大全 C#线程池的实现相关的知识，希望对你有一定的参考价值。

C#线程池的实现 以下文字资料是由(全榜网网www.cha138.com)小编为大家搜集整理后发布的内容，让我们赶快一起来看一下吧！

　　具体的需求是在某一时间点只有N个线程在并发执行如果有多余的线程则排队等候~ 还真是费尽心思啊~最终还是被我攻克了下面我就来说说具体的实现

　　C#提供了Mutex与Interlocked这两个与线程相关的类都在Threading命名空间下! Mutex中提供了WiteOne ReleaseMutex 两个实例方法 WiteOne的作用是阻塞当前线程提供对该线程的原子操作也就是说当一个线程遇到WiteOne的时候如果在WiteOne里面没有线程在操作则此线程进去操作而里面有线程的时候所有到此的线程均需要排队等候里面的线程执行完毕而控制这样操作的结束标记就是使用ReleaseMutex 方法!

　　就好比WiteOne是一把锁一样~而ReleaseMutex 就是一把钥匙当个人都看到这个门的时候第一个到达门口的人会看到屋子里没有人则他进去同时会把门锁上后面的人自然要在门口等候当此人在屋子里执行完任务后他会用钥匙把门打开! 出去后把锁交给门口排队的第二位同志第二位同志再做同样的操作如果第一位同志执行完任务以后不把使用权交给第二个人的话而直接退出那么屋子自然就空了下来而门还是锁的~不必担心~门会自动打开只要是前一个人已经不在屋子里即可~

　　然后再来说说这个Interlocked 官方说明是对一个变量进行原子操作进行递增或者递减然后保存原子操作的概念就是有且只有一个线程在对此变量进行操作~不准其他线程干预的操作当对一个变量进行原子操作的时候此变量就会加锁而其他线程是无法访问的只能挂起等候此变量解锁我感觉实际上使用的也就是Mutex来实现的

　　好了开始说说具体的实现吧

public class MutexTest

　　private static int poolFlag = ;//标记

　　private const int amountThread = ;//线程总量

　　private const int maxThread = ;//可执行线程最大数量

　　private static Mutex muxConsole = new Mutex() ;

　　public static void Main()

　　for ( int i = ;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) ;//标记+

　　if (poolFlag != maxThread) //判断是否等于上限

　muxConsole ReleaseMutex(); //如果此线程达不到可执行线程上限则继续开通让后面的线程进来

　　Console WriteLine( 正在运行 Thread CurrentThread Name ) ;

　　Thread Sleep( ); //模拟执行

　　Console WriteLine( 已经中止 Thread CurrentThread Name ) ;

　　//标记

　　Interlocked Decrement(ref poolFlag) ;

cha138/Article/program/net/201311/14555