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_thread.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();
        }
    }
}

运行结果：