您的位置:首页 > 大数据 > 人工智能

【深度好文】多线程之WaitHandle-->派生-》Semaphore信号量构造

2017-01-19 10:58 344 查看
Semaphore 继承自WaitHandle。

信号量说简单点就是为了线程同步,或者说是为了限制线程能运行的数量。

//创建一个限制资源类
//资源数为5,开放资源数为2
//主线程自动占有3个资源
semaphore = new Semaphore(2, 5);

那它又是怎么限制线程的数量的哩?是因为它内部有个计数器,比如你想限制最多5个线程运行,那么这个计数器的值就会被设置成5,如果一个线程调用了 这个Semaphore,那么它的计数器就会相应的减1,直到这个计数器变为0。这时,如果有另一个线程继续调用这个Semaphore,那么这个线程就 会被阻塞(计数器都被WaitOne()方法调用每次减1 减完了)

获得Semaphore的线程处理完它的逻辑之后,你就可以调用它的Release()或Release(1)函数将它的计数器重新加1,这样其它被阻塞的线程就可以得到调用了

Full codes:

class SemaphoreDemo
{

static Semaphore semaphore;

static void Main(string[] args)
{
//创建一个限制资源类
//资源数为5,开放资源数为2
//主线程自动占有3个资源
semaphore = new Semaphore(2, 5);

//开启3个线程,让它们竞争剩余的2个资源
for (int i = 0; i < 3; i++)
{
Thread t = new Thread(new ParameterizedThreadStart(WorkerProc));
t.Name = "Thread" + i;
t.Start(t.Name);
}

System.Console.ReadKey();
}

static void WorkerProc(Object obj)
{
Console.WriteLine(string.Format("线程:{0}准备执行",obj));
semaphore.WaitOne();
Console.WriteLine(string.Format("线程:{0}开始执行了,停留5秒钟", obj));
Thread.Sleep(5000);
Console.WriteLine(string.Format("线程:{0}执行结束了,释放信号量", obj));
semaphore.Release();
}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: