信号量Semaphore

发布时间:2017-7-1 10:58:38编辑:www.fx114.net 分享查询网我要评论
本篇文章主要介绍了"信号量Semaphore ",主要涉及到信号量Semaphore 方面的内容,对于信号量Semaphore 感兴趣的同学可以参考一下。

信号量Semaphore

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

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

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

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;

namespace Semaphore1
{
    class Program
    {
        //我设置一个最大允许5个线程允许的信号量
        //并将它的计数器的初始值设为0
        //这就是说除了调用该信号量的线程都将被阻塞
        static Semaphore semaphore = new Semaphore(0, 5);

        static void Main(string[] args)
        {
            for (int i = 1; i <= 5; i++)
            {
                Thread thread = new Thread(new ParameterizedThreadStart(work));

                thread.Start(i);
            }

            Thread.Sleep(1000);
            Console.WriteLine("Main thread over!");

            //释放信号量,将初始值设回5,你可以将
            //将这个函数看成你给它传的是多少值,计数器
            //就会加多少回去,Release()相当于是Release(1)
            semaphore.Release(5);
        }

        static void work(object obj)
        {
            semaphore.WaitOne();

            Console.WriteLine("Thread {0} start!",obj);
            
            semaphore.Release();
        }
    }
}

结果如下图所示,其它的线程只有等到主线程释放才会执行,因为我给信号量计数器的初始值是0,所以其它线程在主线程释放前都会被阻塞。而后,我在主线程直接用Release()函数将计数器置为5,所以5个线程可以同时得到执行。

image


上一篇:Python之路【第十一篇】: 进程与线程
下一篇:MySQL查看SQL语句执行效率

相关文章

相关评论

本站评论功能暂时取消,后续此功能例行通知。

一、不得利用本站危害国家安全、泄露国家秘密,不得侵犯国家社会集体的和公民的合法权益,不得利用本站制作、复制和传播不法有害信息!

二、互相尊重,对自己的言论和行为负责。

好贷网好贷款