C#資源池限制實例分析

這篇“C#資源池限制實例分析”文章的知識點大部分人都不太理解，所以小編給大家總結(jié)了以下內(nèi)容，內(nèi)容詳細(xì)，步驟清晰，具有一定的借鑒價值，希望大家閱讀完這篇文章能有所收獲，下面我們一起來看看這篇“C#資源池限制實例分析”文章吧。

Semaphore、SemaphoreSlim 類

兩者都可以限制同時訪問某一資源或資源池的線程數(shù)。

Semaphore 類

這里，先列出 Semaphore 類常用的 API。

其構(gòu)造函數(shù)如下：

Semaphore 使用純粹的內(nèi)核時間(kernel-time)方式(等待時間很短)，并且支持在不同的進(jìn)程間同步線程(像Mutex)。

Semaphore 常用方法如下：

示例

我們來直接寫代碼，這里使用 《原子操作 Interlocked》 中的示例，現(xiàn)在我們要求，采用多個線程執(zhí)行計算，但是只允許最多三個線程同時執(zhí)行運行。

使用 Semaphore ，有四個個步驟：

new 實例化 Semaphore，并設(shè)置最大線程數(shù)、初始化時可進(jìn)入線程數(shù)；

使用 .WaitOne(); 獲取進(jìn)入權(quán)限(在獲得進(jìn)入權(quán)限前，線程處于阻塞狀態(tài))。

離開時使用 Release() 釋放占用。

Close() 釋放Semaphore 對象。

《原子操作 Interlocked》 中的示例改進(jìn)如下：

    class Program
    {
        // 求和
        private static int sum = 0;
        private static Semaphore _pool;

        // 判斷十個線程是否結(jié)束了。
        private static int isComplete = 0;
        // 第一個程序
        static void Main(string[] args)
        {
            Console.WriteLine("執(zhí)行程序");

            // 設(shè)置允許最大三個線程進(jìn)入資源池
            // 一開始設(shè)置為0，就是初始化時允許幾個線程進(jìn)入
            // 這里設(shè)置為0，后面按下按鍵時，可以放通三個線程
            _pool = new Semaphore(0, 3);
            for (int i = 0; i < 10; i++)
            {
                Thread thread = new Thread(new ParameterizedThreadStart(AddOne));
                thread.Start(i + 1);
            }
            Console.ForegroundColor = ConsoleColor.Red;
            Console.WriteLine("任意按下鍵(不要按關(guān)機(jī)鍵)，可以打開資源池");
            Console.ForegroundColor = ConsoleColor.White;
            Console.ReadKey();

            // 準(zhǔn)許三個線程進(jìn)入
            _pool.Release(3);

            // 這里沒有任何意義，就單純?yōu)榱搜菔静榭唇Y(jié)果。
            // 等待所有線程完成任務(wù)
            while (true)
            {
                if (isComplete >= 10)
                    break;
                Thread.Sleep(TimeSpan.FromSeconds(1));
            }
            Console.WriteLine("sum = " + sum);

            // 釋放池
            _pool.Close();
            
        }

        public static void AddOne(object n)
        {
            Console.WriteLine($"    線程{(int)n}啟動，進(jìn)入隊列");
            // 進(jìn)入隊列等待
            _pool.WaitOne();
            Console.WriteLine($"第{(int)n}個線程進(jìn)入資源池");
            // 進(jìn)入資源池
            for (int i = 0; i < 10; i++)
            {
                Interlocked.Add(ref sum, 1);
                Thread.Sleep(TimeSpan.FromMilliseconds(500));
            }
            // 解除占用的資源池
            _pool.Release();
            isComplete += 1;
            Console.WriteLine($"                     第{(int)n}個線程退出資源池");
        }
    }

看著代碼有點多，快去運行一下，看看結(jié)果。

示例說明

實例化 Semaphore 使用了new Semaphore(0,3); ，其構(gòu)造函數(shù)原型為

public Semaphore(int initialCount, int maximumCount);

initialCount 表示一開始允許幾個進(jìn)程進(jìn)入資源池，如果設(shè)置為0，所有線程都不能進(jìn)入，要一直等資源池放通。

maximumCount 表示最大允許幾個線程進(jìn)入資源池。

Release() 表示退出信號量并返回前一個計數(shù)。這個計數(shù)指的是資源池還可以進(jìn)入多少個線程。

可以看一下下面的示例：

        private static Semaphore _pool;
        static void Main(string[] args)
        {
            _pool = new Semaphore(0, 5);
            _pool.Release(5);
            new Thread(AddOne).Start();
            Thread.Sleep(TimeSpan.FromSeconds(10));
            _pool.Close();
        }

        public static void AddOne()
        {
            _pool.WaitOne();
            Thread.Sleep(1000);
            int count = _pool.Release();
            Console.WriteLine("在此線程退出資源池前，資源池還有多少線程可以進(jìn)入？" + count);
        }

信號量

前面我們學(xué)習(xí)到 Mutex，這個類是全局操作系統(tǒng)起作用的。我們從 Mutex 和 Semphore 中，也看到了 信號量這個東西。

信號量分為兩種類型：本地信號量和命名系統(tǒng)信號量。

• 命名系統(tǒng)信號量在整個操作系統(tǒng)中均可見，可用于同步進(jìn)程的活動。

• 局部信號量僅存在于進(jìn)程內(nèi)。

當(dāng) name 為 null 或者為空時，Mutex 的信號量時局部信號量，否則 Mutex 的信號量是命名系統(tǒng)信號量。

Semaphore 的話，也是兩種情況都有。

如果使用接受名稱的構(gòu)造函數(shù)創(chuàng)建 Semaphor 對象，則該對象將與該名稱的操作系統(tǒng)信號量關(guān)聯(lián)。

兩個構(gòu)造函數(shù)：

Semaphore(Int32, Int32, String)
Semaphore(Int32, Int32, String, Boolean)

上面的構(gòu)造函數(shù)可以創(chuàng)建多個表示同一命名系統(tǒng)信號量的 Semaphore 對象，并可以使用 OpenExisting 方法打開現(xiàn)有的已命名系統(tǒng)信號量。

我們上面使用的示例就是局部信號量，進(jìn)程中引用本地 Semaphore 對象的所有線程都可以使用。 每個 Semaphore 對象都是單獨的本地信號量。

SemaphoreSlim類

SemaphoreSlim 跟 Semaphore 有啥關(guān)系？

微軟文檔：

SemaphoreSlim 表示對可同時訪問資源或資源池的線程數(shù)加以限制的 Semaphore 的輕量替代。

SemaphoreSlim 不使用信號量，不支持進(jìn)程間同步，只能在進(jìn)程內(nèi)使用。

它有兩個構(gòu)造函數(shù)：

示例

我們改造一下前面 Semaphore 中的示例：

    class Program
    {
        // 求和
        private static int sum = 0;
        private static SemaphoreSlim _pool;

        // 判斷十個線程是否結(jié)束了。
        private static int isComplete = 0;
        static void Main(string[] args)
        {
            Console.WriteLine("執(zhí)行程序");

            // 設(shè)置允許最大三個線程進(jìn)入資源池
            // 一開始設(shè)置為0，就是初始化時允許幾個線程進(jìn)入
            // 這里設(shè)置為0，后面按下按鍵時，可以放通三個線程
            _pool = new SemaphoreSlim(0, 3);
            for (int i = 0; i < 10; i++)
            {
                Thread thread = new Thread(new ParameterizedThreadStart(AddOne));
                thread.Start(i + 1);
            }

            Console.WriteLine("任意按下鍵(不要按關(guān)機(jī)鍵)，可以打開資源池");
            Console.ReadKey();
            // 
            _pool.Release(3);

            // 這里沒有任何意義，就單純?yōu)榱搜菔静榭唇Y(jié)果。
            // 等待所有線程完成任務(wù)
            while (true)
            {
                if (isComplete >= 10)
                    break;
                Thread.Sleep(TimeSpan.FromSeconds(1));
            }
            Console.WriteLine("sum = " + sum);
            // 釋放池
        }

        public static void AddOne(object n)
        {
            Console.WriteLine($"    線程{(int)n}啟動，進(jìn)入隊列");
            // 進(jìn)入隊列等待
            _pool.Wait();
            Console.WriteLine($"第{(int)n}個線程進(jìn)入資源池");
            // 進(jìn)入資源池
            for (int i = 0; i < 10; i++)
            {
                Interlocked.Add(ref sum, 1);
                Thread.Sleep(TimeSpan.FromMilliseconds(200));
            }
            // 解除占用的資源池
            _pool.Release();
            isComplete += 1;
            Console.WriteLine($"                     第{(int)n}個線程退出資源池");
        }
    }

SemaphoreSlim 不需要 Close()。

兩者在代碼上的區(qū)別是就這么簡單。

區(qū)別

如果使用下面的構(gòu)造函數(shù)實例化 Semaphor(參數(shù)name不能為空)，那么創(chuàng)建的對象在整個操作系統(tǒng)內(nèi)都有效。

public Semaphore (int initialCount, int maximumCount, string name);

Semaphorslim 則只在進(jìn)程內(nèi)內(nèi)有效。

SemaphoreSlim 類不會對 Wait、WaitAsync 和 Release 方法的調(diào)用強制執(zhí)行線程或任務(wù)標(biāo)識。

而 Semaphor 類，會對此進(jìn)行嚴(yán)格監(jiān)控，如果對應(yīng)調(diào)用數(shù)量不一致，會出現(xiàn)異常。

此外，如果使用 SemaphoreSlim(Int32 maximumCount) 構(gòu)造函數(shù)來實例化 SemaphoreSlim 對象，獲取其 CurrentCount 屬性，其值可能會大于 maximumCount。 編程人員應(yīng)負(fù)責(zé)確保調(diào)用一個 Wait 或 WaitAsync 方法，便調(diào)用一個 Release。

這就好像筆筒里面的筆，沒有監(jiān)控，使用這使用完畢后，都應(yīng)該將筆放進(jìn)去。如果原先有10支筆，每次使用不放進(jìn)去，或者將別的地方的筆放進(jìn)去，那么最后數(shù)量就不是10了。

以上就是關(guān)于“C#資源池限制實例分析”這篇文章的內(nèi)容，相信大家都有了一定的了解，希望小編分享的內(nèi)容對大家有幫助，若想了解更多相關(guān)的知識內(nèi)容，請關(guān)注億速云行業(yè)資訊頻道。