。

在进入一个关键代码段之前#xff0c;线程必须获取一个信号量。

一旦该关键代码段完成了#xff0c;那么该线程必须释…信号量(Semaphore)有时被称为信号灯是在多线程环境下使用的一种设施是可以用来保证两个或多个关键代码段不被并发调用。

在进入一个关键代码段之前线程必须获取一个信号量。

一旦该关键代码段完成了那么该线程必须释放信号量。

其它想进入该关键代码段的线程必须等待直到第一个线程释放信号量。

以下主要介绍C#中Semaphore

CountdownEvent

限制可同时访问某一资源或资源池的线程数。

.NET中的信号量Semaphore是操作系统维持的一个整数。

当整数位0时。

其他线程无法进入。

当整数大于0时线程可以进入。

每当一个线程进入整数-1线程退出后整数1。

整数不能超过信号量的最大请求数。

信号量在初始化的时候可以指定这个整数的初始值。

System.Threading.Semaphore类的构造函数的两个参数第一个就是信号量的内部整数初始值也就是初始请求数第二个参数就是最大请求数。

2CountdownEvent

System.Threading.CountdownEvent

CountdownEvent

表示在计数变为0时处于有信号状态的同步基元通过信号机制CountdownEvent当有新的需要同步的任务产生时就调用AddCount增加它的计数当有任务到达同步点是就调用Signal函数减小它的计数当CountdownEvent的计数为零时就表示所有需要同步的任务已经完成。

CountDownEvent与Barrier相似所不同的是CountDownEvent调用成员函数Wait()将阻塞直至成员函数Signal()

被调用达特定的次数这时CountDownEvent称作就绪态对于处于就绪态的CountDownEvent调用Wait()函数将不会再阻塞只有手动调用Reset()函数后调用Wait()函数将再次阻塞。

CountDownEvent可以通过TryAddCount()和AddCount()函数来增加函数Signal()

需被调用的次数但只有当CountDownEvent处于未就绪态时才会成功。

否则根据调用函数的不同将有可能抛出异常。

.NET中的信号量Semaphore是操作系统维持的一个整数。

当整数位0时。

其他线程无法进入。

当整数大于0时线程可以进入。

每当一个线程进入整数-1线程退出后整数1。

整数不能超过信号量的最大请求数。

信号量在初始化的时候可以指定这个整数的初始值。

System.Threading.Semaphore类的构造函数的两个参数第一个就是信号量的内部整数初始值也就是初始请求数第二个参数就是最大请求数。

using

填充Thread.Sleep()间隔使输出更有序。

private

static

Main(){//创建一个信号量这个信号量最多可以满足三个信号量//并发请求。

初始计数为0//整个信号量计数是初始的//主程序线程拥有。

//_pool

new

ParameterizedThreadStart(Worker));//

启动线程传递编号。

t.Start(i);}//等待半秒钟让所有的线程启动和阻塞信号量。

Thread.Sleep(500);//主线程开始持有整个信号量计数。

//

调用Release(3)带来返回信号量的最大值允许等待的线程进入信号量一次最多3个。

Console.WriteLine(主线程调用

Release(3));_pool.Release(3);Console.WriteLine(主线程退出);Console.ReadKey();}private

static

num){//每个工作线程开始请求信号量Console.WriteLine(Thread

{0}

padding);Console.WriteLine(Thread

{0}

CountDownEvent调用成员函数Wait()将阻塞直至成员函数Signal()被调用达特定的次数这时CountDownEvent称作就绪态对于处于就绪态的CountDownEvent调用Wait()函数将不会再阻塞只有手动调用Reset()函数后调用Wait()函数将再次阻塞。

CountDownEvent可以通过TryAddCount()和AddCount()函数来增加函数Signal()需被调用的次数但只有当CountDownEvent处于未就绪态时才会成功。

否则根据调用函数的不同将有可能抛出异常。

using

System.Threading.Tasks;namespace

ConsoleApplication

{Thread.Sleep(500);Console.WriteLine(thread

complete);_count.Signal();});Task.Factory.StartNew(()

{Thread.Sleep(1000);Console.WriteLine(thread

complete);_count.Signal();});Task.Factory.StartNew(()

{Thread.Sleep(2000);Console.WriteLine(thread

complete);_count.Signal();});//_count.AddCount();//调用AddCount增加计数Console.WriteLine(waiting

tasks....);_count.Wait();Console.WriteLine(all

task

completed);Console.ReadKey();}}