動機

    從開始接觸多線（進）程編程模型開始，學習的就是和信號量(semaphore)相關的同步原語。不知道為什么 .net framework 里卻沒有相應的東東。要命的是, 我以前有很多久經考驗的c++代碼都是用她來實現的, 為了不使革命先烈的藥白吃, 血白流, 只好自己生一個了。

什么是信號量(semaphore)

    如果你已經了解信號量(semaphore)的概念了，請跳過這一段。
   
    信號量(semaphore)是在多線程環境下使用的一種設施, 它負責協調各個線程, 以保證它們能夠正確、合理的使用公共資源。

    我們來看看一個停車場是怎樣運作的。為了簡單起見，假設停車場只有三個車位，一開始三個車位都是空的。這是如果同時來了五輛車，看門人允許其中三輛不受阻礙的進入，然后放下車攔，剩下的車則必須在入口等待，此后來的車也都不得不在入口處等待。這時，有一輛車離開停車場，看門人得知后，打開車攔，放入一輛，如果又離開兩輛，則又可以放入兩輛，如此往復。

    在這個停車場系統中，車位是公共資源，每輛車好比一個線程，看門人起的就是信號量的作用。

    更進一步，信號量的特性如下：信號量是一個非負整數（車位數），所有通過它的線程（車輛）都會將該整數減一（通過它當然是為了使用資源），當該整數值為零時，所有試圖通過它的線程都將處于等待狀態。在信號量上我們定義兩種操作： wait（等待） 和 release（釋放）。 當一個線程調用wait等待）操作時，它要么通過然后將信號量減一，要么一自等下去，直到信號量大于一或超時。release（釋放）實際上是在信號量上執行加操作，對應于車輛離開停車場，該操作之所以叫做“釋放”是應為加操作實際上是釋放了由信號量守護的資源。

實現

   大家都知道，.net framework類庫中提供的線程同步設施包括：

    monitor， autoresetevent， manualresetevent，mutex，readwritelock和 interlock。 其中 autoresetevent， manualresetevent，mutex派生自waithandler，它們實際上是封裝了操作系統提供的內核對象。而其它的應當是在.net虛擬機中土生土長的。顯然來自操作系統內核對象的設施使用起來效率要差一些。不過效率并不是我們這里要考慮的問題，我們將使用兩個 monitor 和 一個manualresetevent 對象來模擬一個信號量。

代碼如下：

    public class semaphore
    {
        private manualresetevent waitevent = new manualresetevent(false);
        private object syncobjwait = new object();
        private int     maxcount = 1;      http://www.alixixi.com/dev/web/aspnet/aspnet1/2007/file://最大資源數
        private int     currentcount = 0;  http://www.alixixi.com/dev/web/aspnet/aspnet1/2007/file://當前資源數

        public semaphore()
        {

        }

        public semaphore( int maxcount )
        {
            this.maxcount = maxcount;
        }

        public bool wait()
        {
            lock( syncobjwait )      http://www.alixixi.com/dev/web/aspnet/aspnet1/2007/file://只能一個線程進入下面代碼
            {
                bool waitresult = this.waitevent.waitone();   http://www.alixixi.com/dev/web/aspnet/aspnet1/2007/file://在此等待資源數大于零
                if( waitresult )
                {
                    lock( this )
                    {
                        if( currentcount > 0 )
                        {
                            currentcount--;
                            if( currentcount == 0 )
                            {
                                this.waitevent.reset();
                            }

                        }
                        else
                        {
                            system.diagnostics.debug.assert( false, "semaphore is not allow current count < 0" );
                        }
                    }
                }
                return waitresult;
            }
        }

        /**//// <summary>
        /// 允許超時返回的 wait 操作
        /// </summary>
        /// <param name="millisecondstimeout"></param>
        /// <returns></returns>
        public bool wait( int millisecondstimeout )
        {
            lock( syncobjwait )  // monitor 確保該范圍類代碼在臨界區內
            {
                bool waitresult = this.waitevent.waitone(millisecondstimeout,false);
                if( waitresult )
                {
                    lock( this )
                    {
                        if( currentcount > 0 )
                        {
                            currentcount--;
                            if( currentcount == 0 )
                            {
                                this.waitevent.reset();
                            }

                        }
                        else
                        {
                            system.diagnostics.debug.assert( false, "semaphore is not allow current count < 0" );
                        }
                    }
                }
                return waitresult;
            }
        }

        public bool release()
        {
            lock( this ) // monitor 確保該范圍類代碼在臨界區內
            {
                currentcount++;
                if( currentcount > this.maxcount )
                {
                    currentcount = this.maxcount;
                    return false;
                }
                this.waitevent.set();  http://www.alixixi.com/dev/web/aspnet/aspnet1/2007/file://允許調用wait的線程進入
            }
            return true;
        }

    }