public class DoubleCacheQueue<T> { public DoubleCacheQueue() { } public T Dequeue() { T t = default(T); if (readQueue.Count > 0) t= readQueue.Dequeue(); else { writeQueue = Interlocked.Exchange<Queue<T>>(ref readQueue, writeQueue); } return t; } public void Enqueue(T item) { writeQueue.Enqueue(item); } public int Count { get { return readQueue.Count; } } //讀緩沖 private Queue<T> readQueue = new Queue<T>(); //寫緩沖 private Queue<T> writeQueue = new Queue<T>(); }
問下大家,這段代碼能保證多線程安全嗎?
這段代碼能保證多線程安全嗎?
哆啦的時(shí)光機(jī)
2018-12-06 23:21:00
