C#Semaphore信號量用法


參考博客:http://www.cnblogs.com/free722/archive/2011/04/03/2004926.html

http://www.cnblogs.com/heqichang/archive/2011/12/24/2300301.html

信號量說簡單點就是為了線程同步,或者說是為了限制線程能運行的數量。

那它又是怎么限制線程的數量的哩?是因為它內部有個計數器,比如你想限制最多5個線程運行,那么這個計數器的值就會被設置成5,如果一個線程調用了 這個Semaphore,那么它的計數器就會相應的減1,直到這個計數器變為0。這時,如果有另一個線程繼續調用這個Semaphore,那么這個線程就 會被阻塞。

獲得Semaphore的線程處理完它的邏輯之后,你就可以調用它的Release()函數將它的計數器重新加1,這樣其它被阻塞的線程就可以得到調用了。

    class SemaphoreDemo
    {

        static Semaphore semaphore;

        static void Main(string[] args)
        {
            //創建一個限制資源類
            //資源數為5,開放資源數為2
            //主線程自動占有3個資源
            semaphore = new Semaphore(2, 5);

            //開啟3個線程,讓它們競爭剩余的2個資源
            for (int i = 0; i < 3; i++)
            {
                Thread t = new Thread(new ParameterizedThreadStart(WorkerProc));
                t.Name = "Thread" + i;
                t.Start(t.Name);
            }

            System.Console.ReadKey();
        }

        static void WorkerProc(Object obj)
        {
            Console.WriteLine(string.Format("線程:{0}准備執行",obj));
            semaphore.WaitOne();
            Console.WriteLine(string.Format("線程:{0}開始執行了,停留5秒鍾", obj));
            Thread.Sleep(5000);
            Console.WriteLine(string.Format("線程:{0}執行結束了,釋放信號量", obj));
            semaphore.Release();
        }

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM