博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
信号量Semaphore
阅读量:6122 次
发布时间:2019-06-21

本文共 1303 字,大约阅读时间需要 4 分钟。

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

那它又是怎么限制线程的数量的哩?是因为它内部有个计数器,比如你想限制最多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个线程可以同时得到执行。

 

转载地址:http://hlgka.baihongyu.com/

你可能感兴趣的文章
10windows_font_text
查看>>
修改远程桌面连接端口(PortNumber)
查看>>
Java Web整合开发(31) -- Spring的Web模块
查看>>
“热补丁”Hook,多线程下InlineHook解决方法
查看>>
类 BufferedReader
查看>>
对质量的追求
查看>>
Iscroll上拉加载、下拉刷新功能代码实现
查看>>
hive对lzo文件并行处理的关键点
查看>>
【十大经典数据挖掘算法】kNN
查看>>
Ubuntu16.04中搭建TFTP 和 NFS 服务器
查看>>
触发器中判断操作是Insert还是Update还是Delete
查看>>
redis学习总结2
查看>>
南阳329--循环小数(Kmp)
查看>>
OpenGIS Simple feature access
查看>>
redis数据库服务器开启的三种方式
查看>>
9.20...
查看>>
php 安装configure 配置选项 保存
查看>>
JS对图片缩放处理
查看>>
openssl evp 哈希算法(md5,sha1,sha256)
查看>>
Java面试常考知识点
查看>>