c＃線程同步

Question

我正在爲wp7開發一個應用程序。我需要一個同步讀取和寫入。 所以我在隊列創建此類

public class SynchronizedPacketQueue 
{ 
    [DataMember] 
    public List<Packet> packetsQ; 

    public SynchronizedPacketQueue() 
    { 
     packetsQ = new List<Packet>(); 
    } 

    public int Count 
    { 
     get { return packetsQ.Count; } 
     private set{} 
    } 


    public Packet Dequeue() 
    { 
     lock (packetsQ) 
     { 
      if (packetsQ.Count == 0) 
      { 
       Monitor.Wait(packetsQ); 

      } 
      Packet packet = packetsQ[0]; 
      packetsQ.RemoveAt(0); 
      return packet; 
     } 
    } 

    public void Enqueue(Packet packet) 
    { 
     lock (packetsQ) 
     { 
      packetsQ.Add(packet); 
      Monitor.Pulse(packetsQ); 
     } 
    } 
} 

現在我threadwrite入隊的分組和threadread讀取來自queue.Both是無限運行的線程。 但我不知道一些如何在packetQ.removeat（0）處阻塞threadwrite。

Answer 1

我想你應該創建鎖對象，並用它你的鎖

public class SynchronizedPacketQueue 
    { 
     [DataMember] 
     public List<Packet> packetsQ; 
     private object mylock = new object(); 

     public SynchronizedPacketQueue() 
     { 
     packetsQ = new List<Packet>(); 
     } 

    public int Count 
    { 
     get { return packetsQ.Count; } 
     private set{} 
    } 


    public Packet Dequeue() 
    { 
     lock (mylock) 
     { 
      if (packetsQ.Count == 0) 
      { 
       Monitor.Wait(mylock); 

      } 
      Packet packet = packetsQ[0]; 
      packetsQ.RemoveAt(0); 
      return packet; 
     } 
    } 

    public void Enqueue(Packet packet) 
    { 
     lock (mylock) 
     { 
      packetsQ.Add(packet); 
      Monitor.Pulse(mylock); 
     } 
    } 
}