c# Semaphore（信号量）

参考：

http://blog.csdn.net/feilongzaitianhehe/article/details/51460529

http://www.cnblogs.com/tianzhiliang/archive/2010/08/31/1813635.html

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

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

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

类似互斥锁，但它可以允许多个线程同时访问一个共享资源

通过使用一个计数器来控制对共享资源的访问，如果计数器大于0，就允许访问，如果等于0，就拒绝访问。计数器累计的是“许可证”的数目，为了访问某个资源。线程必须从信号量获取一个许可证。

通常在使用信号量时，希望访问共享资源的线程将尝试获取一个许可证，如果信号量的计数器大于0，线程将获取一个许可证并将信号量的计数器减1，否则先线程将阻塞，直到获取一个许可证；当线程不再需要共享资源时，将释放锁拥有的许可证，并将许可证的数量加1，如果有其他的线程正在等待许可证，那么该线程将立刻获取许可证。

另外，允许同时访问的资源的进程数量是在创建信号量时指定的，如果创建一个允许进程访问的信号量数目为1，则该信号量就和互斥锁的用法一样。

//
// 摘要:
//     初始化 System.Threading.Semaphore 类的新实例，并指定初始入口数和最大并发入口数。
//
// 参数:
//   initialCount:
//     可以同时授予的信号量的初始请求数。
//
//   maximumCount:
//     可以同时授予的信号量的最大请求数。
//
// 异常:
//   T:System.ArgumentException:
//     initialCount 大于 maximumCount。
//
//   T:System.ArgumentOutOfRangeException:
//     maximumCount 为小于 1。- 或 -initialCount 小于 0。
[SecuritySafeCritical]
public Semaphore(int initialCount, int maximumCount);

获取许可证使用WaitOne（）；

不需要时释放使用 public int Release（），或者public int Release（int releaseCount）；

实例：

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

namespace ConsoleApp1
{
class mythread
{
public Thread m_thread;
static Semaphore m_semaphore = new Semaphore(2, 2);

public mythread(string name)
{
m_thread = new Thread(this.run);
m_t
ac8b
hread.Name = name;
m_thread.Start();
}

void run()
{
Console.WriteLine(m_thread.Name + ":正在等待一个许可证...");
//申请一个许可证
m_semaphore.WaitOne();
Console.WriteLine(m_thread.Name + ":申请到许可证...");

for (int i = 0; i < 4; i++)
{
Console.WriteLine(m_thread.Name + ":" + i);
Thread.Sleep(1000);
}

Console.WriteLine(m_thread.Name + ":释放许可证...");
m_semaphore.Release();
}
}
}

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

namespace ConsoleApp1
{
class Program
{
static void Main(string[] args)
{
MySemaphore();
}

static void MySemaphore()
{
mythread thread1 = new mythread("Thrd # 1 ");
mythread thread2 = new mythread("Thrd # 2 ");
mythread thread3 = new mythread("Thrd # 3 ");
mythread thread4 = new mythread("Thrd # 4 ");
thread1.m_thread.Join();
thread2.m_thread.Join();
thread3.m_thread.Join();
thread4.m_thread.Join();
}
}
}

运行结果：