系列文章導(dǎo)航：

C#多線程學(xué)習(xí)(一) 多線程的相關(guān)概念

C#多線程學(xué)習(xí)(二) 如何操縱一個(gè)線程

C#多線程學(xué)習(xí)(三) 生產(chǎn)者和消費(fèi)者

C#多線程學(xué)習(xí)(四) 多線程的自動(dòng)管理(線程池)

C#多線程學(xué)習(xí)(五) 多線程的自動(dòng)管理(定時(shí)器)

C#多線程學(xué)習(xí)(六) 互斥對(duì)象

前面說過，每個(gè)線程都有自己的資源，但是代碼區(qū)是共享的，即每個(gè)線程都可以執(zhí)行相同的函數(shù)。這可能帶來的問題就是幾個(gè)線程同時(shí)執(zhí)行一個(gè)函數(shù)，導(dǎo)致數(shù)據(jù)的混亂，產(chǎn)生不可預(yù)料的結(jié)果，因此我們必須避免這種情況的發(fā)生。

C#提供了一個(gè)關(guān)鍵字lock，它可以把一段代碼定義為互斥段（critical section），互斥段在一個(gè)時(shí)刻內(nèi)只允許一個(gè)線程進(jìn)入執(zhí)行，而其他線程必須等待。在C#中，關(guān)鍵字lock定義如下：

lock(expression) statement_block

expression代表你希望跟蹤的對(duì)象，通常是對(duì)象引用。

• 如果你想保護(hù)一個(gè)類的實(shí)例，一般地，你可以使用this；
• 如果你想保護(hù)一個(gè)靜態(tài)變量（如互斥代碼段在一個(gè)靜態(tài)方法內(nèi)部），一般使用類名就可以了。

而statement_block就是互斥段的代碼，這段代碼在一個(gè)時(shí)刻內(nèi)只可能被一個(gè)線程執(zhí)行。

下面是一個(gè)使用lock關(guān)鍵字的典型例子，在注釋里說明了lock關(guān)鍵字的用法和用途。

示例如下：

Code
using System;
using System.Threading;

namespace ThreadSimple
{
    internal class Account 
    {
        int balance;
        Random r = new Random();
        
        internal Account(int initial) 
        {
            balance = initial;
        } 
        internal int Withdraw(int amount) 
        {
            if (balance < 0)
            {
                //如果balance小于0則拋出異常
                throw new Exception("Negative Balance");
            }
            //下面的代碼保證在當(dāng)前線程修改balance的值完成之前
            //不會(huì)有其他線程也執(zhí)行這段代碼來修改balance的值
            //因此，balance的值是不可能小于0 的
            lock (this)
            {
                Console.WriteLine("Current Thread:"+Thread.CurrentThread.Name);
                //如果沒有l(wèi)ock關(guān)鍵字的保護(hù)，那么可能在執(zhí)行完if的條件判斷之后
                //另外一個(gè)線程卻執(zhí)行了balance=balance-amount修改了balance的值
                //而這個(gè)修改對(duì)這個(gè)線程是不可見的，所以可能導(dǎo)致這時(shí)if的條件已經(jīng)不成立了
                //但是，這個(gè)線程卻繼續(xù)執(zhí)行balance=balance-amount，所以導(dǎo)致balance可能小于0
                if (balance >= amount) 
                {
                    Thread.Sleep(5);
                    balance = balance - amount;
                    return amount;
                } 
                else 
                {
                    return 0; // transaction rejected
                  }
            }
        }
        internal void DoTransactions() 
        {
            for (int i = 0; i < 100; i++) 
            Withdraw(r.Next(-50, 100));
        }
    } 
    internal class Test 
    {
        static internal Thread[] threads = new Thread[10];
        public static void Main() 
        {
            Account acc = new Account (0);
            for (int i = 0; i < 10; i++) 
            {
                Thread t = new Thread(new ThreadStart(acc.DoTransactions));
                threads[i] = t;
            }
            for (int i = 0; i < 10; i++) 
                threads[i].Name=i.ToString();
            for (int i = 0; i < 10; i++) 
                threads[i].Start();
            Console.ReadLine();
        }
    }
}

系列文章導(dǎo)航：

C#多線程學(xué)習(xí)(一) 多線程的相關(guān)概念

C#多線程學(xué)習(xí)(二) 如何操縱一個(gè)線程

C#多線程學(xué)習(xí)(三) 生產(chǎn)者和消費(fèi)者

C#多線程學(xué)習(xí)(四) 多線程的自動(dòng)管理(線程池)

C#多線程學(xué)習(xí)(五) 多線程的自動(dòng)管理(定時(shí)器)

C#多線程學(xué)習(xí)(六) 互斥對(duì)象

對(duì)于任何一個(gè)被Monitor鎖定的對(duì)象，內(nèi)存中都保存著與它相關(guān)的一些信息:

其一是現(xiàn)在持有鎖的線程的引用;

其二是一個(gè)預(yù)備隊(duì)列，隊(duì)列中保存了已經(jīng)準(zhǔn)備好獲取鎖的線程;

其三是一個(gè)等待隊(duì)列，隊(duì)列中保存著當(dāng)前正在等待這個(gè)對(duì)象狀態(tài)改變的隊(duì)列的引用。

當(dāng)擁有對(duì)象鎖的線程準(zhǔn)備釋放鎖時(shí)，它使用Monitor.Pulse()方法通知等待隊(duì)列中的第一個(gè)線程，于是該線程被轉(zhuǎn)移到預(yù)備隊(duì)列中，當(dāng)對(duì)象鎖被釋放時(shí)，在預(yù)備隊(duì)列中的線程可以立即獲得對(duì)象鎖。

下面是一個(gè)展示如何使用lock關(guān)鍵字和Monitor類來實(shí)現(xiàn)線程的同步和通訊的例子，也是一個(gè)典型的生產(chǎn)者與消費(fèi)者問題。

這個(gè)例程中，生產(chǎn)者線程和消費(fèi)者線程是交替進(jìn)行的，生產(chǎn)者寫入一個(gè)數(shù)，消費(fèi)者立即讀取并且顯示（注釋中介紹了該程序的精要所在）。

用到的系統(tǒng)命名空間如下：

using System;

using System.Threading;

首先，定義一個(gè)被操作的對(duì)象的類Cell，在這個(gè)類里，有兩個(gè)方法：ReadFromCell()和WriteToCell。消費(fèi)者線程將調(diào)用ReadFromCell()讀取cellContents的內(nèi)容并且顯示出來，生產(chǎn)者進(jìn)程將調(diào)用WriteToCell()方法向cellContents寫入數(shù)據(jù)。

示例如下：

Code
public class Cell
{
        int cellContents; // Cell對(duì)象里邊的內(nèi)容
        bool readerFlag = false; // 狀態(tài)標(biāo)志，為true時(shí)可以讀取，為false則正在寫入
        public int ReadFromCell( )
        {
            lock(this) // Lock關(guān)鍵字保證了什么，請(qǐng)大家看前面對(duì)lock的介紹
            {
                if (!readerFlag)//如果現(xiàn)在不可讀取
                { 
                    try
                    {
                        //等待WriteToCell方法中調(diào)用Monitor.Pulse()方法
                        Monitor.Wait(this);
                    }
                    catch (SynchronizationLockException e)
                    {
                        Console.WriteLine(e);
                    }
                    catch (ThreadInterruptedException e)
                    {
                        Console.WriteLine(e);
                    }
                }
                Console.WriteLine("Consume: {0}",cellContents);
                readerFlag = false;
                //重置readerFlag標(biāo)志，表示消費(fèi)行為已經(jīng)完成
                Monitor.Pulse(this); 
                //通知WriteToCell()方法（該方法在另外一個(gè)線程中執(zhí)行，等待中）
            }
            return cellContents;
        }
    
        public void WriteToCell(int n)
        {
            lock(this)
            {
                if (readerFlag)
                {
                    try
                    {
                        Monitor.Wait(this);
                    }
                    catch (SynchronizationLockException e)
                    {
                            //當(dāng)同步方法（指Monitor類除Enter之外的方法）在非同步的代碼區(qū)被調(diào)用
                        Console.WriteLine(e);
                    }
                    catch (ThreadInterruptedException e)
                    {
                            //當(dāng)線程在等待狀態(tài)的時(shí)候中止 
                        Console.WriteLine(e);
                    }
                }
                cellContents = n;
                Console.WriteLine("Produce: {0}",cellContents);
                readerFlag = true; 
                Monitor.Pulse(this); 
                //通知另外一個(gè)線程中正在等待的ReadFromCell()方法
            }
        }
}
下面定義生產(chǎn)者類 CellProd 和消費(fèi)者類 CellCons ，它們都只有一個(gè)方法ThreadRun()，以便在Main()函數(shù)中提供給線程的ThreadStart代理對(duì)象，作為線程的入口。
public class CellProd
{
　　    Cell cell; // 被操作的Cell對(duì)象
　　    int quantity = 1; // 生產(chǎn)者生產(chǎn)次數(shù)，初始化為1 

　　    public CellProd(Cell box, int request)
　　    {
        //構(gòu)造函數(shù)
        cell = box; 
        quantity = request; 
　　    }
　　    public void ThreadRun( )
　　    {
        for(int looper=1; looper<=quantity; looper++)
　　　　        cell.WriteToCell(looper); //生產(chǎn)者向操作對(duì)象寫入信息
　　    }
}

public class CellCons
{
　　    Cell cell; 
　　    int quantity = 1; 

　　    public CellCons(Cell box, int request)
　　    {
                //構(gòu)造函數(shù)
        cell = box; 
        quantity = request; 
　　    }
　　    public void ThreadRun( )
　　    {
        int valReturned;
        for(int looper=1; looper<=quantity; looper++)
　　　　        valReturned=cell.ReadFromCell( );//消費(fèi)者從操作對(duì)象中讀取信息
　　    }
} 

NET技術(shù)：C#多線程學(xué)習(xí)(三) 生產(chǎn)者和消費(fèi)者，轉(zhuǎn)載需保留來源！

鄭重聲明：本文版權(quán)歸原作者所有，轉(zhuǎn)載文章僅為傳播更多信息之目的，如作者信息標(biāo)記有誤，請(qǐng)第一時(shí)間聯(lián)系我們修改或刪除，多謝。