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); 
     } 
    } 
}