C# Semaphore

 1 class Program
 2     {
 3         static Semaphore semaphore;
 4         //当前信号量中线程数量
 5         static int count;
 6         //用于生成随机数
 7         static Random r;
 8 
 9         static void Main()
10         {
11             r = new Random();
12             //初始化信号量：初始请求数为1，最大请求数为3
13             semaphore = new Semaphore(1, 3);
14             //放出10个线程
15             for (int i = 0; i < 5; i++)
16                 ThreadPool.QueueUserWorkItem(doo, i + 1);
17             Console.ReadKey(true);
18         }
19 
20         static void doo(object arg)
21         {
22             int id = (int)arg;
23             PrintStatus(id, "等待信号量");
24             //获取一个资源
25             semaphore.WaitOne();
26             PrintStatus(id, "获得信号量开始执行");
27             PrintCount(1);
28             Thread.Sleep(r.Next(1000));
29             PrintStatus(id, "退出");
30             PrintCount(-1);
31             //释放一个资源
32             semaphore.Release();
33 
34         }
35 
36         //输出线程状态
37         static void PrintStatus(int id, string s)
38         {
39             Console.WriteLine("线程{0}：{1}", id, s);
40         }
41 
42         //修改并输出线程数量
43         static void PrintCount(int add)
44         {
45             //在多进程（线程）的操作系统中不能被其它进程（线程）打断的操作就叫原子操作，一个线程在执行其它线程无法抢占。
46             //对两个 32 位整数进行求和并用和替换第一个整数，上述操作作为一个原子操作完成。
47             Interlocked.Add(ref count, add);
48             //以原子操作的形式，将 32 位有符号整数设置为指定的值并返回原始值。
49             Console.WriteLine("=> 信号量值：{0}", Interlocked.Exchange(ref count, count));
50         }
51     }