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的负载平衡上面~

这样我就可以自己控制请求的数量了~