Mercurial > pub > ImplabNet
diff Implab/Parallels/BlockingQueue.cs @ 233:d6fe09f5592c v2
Improved AsyncQueue
Removed ImplabFx
author | cin |
---|---|
date | Wed, 04 Oct 2017 15:44:47 +0300 |
parents | 041b77711262 |
children | 7c7e9ad6fe4a |
line wrap: on
line diff
--- a/Implab/Parallels/BlockingQueue.cs Tue Sep 12 19:07:42 2017 +0300 +++ b/Implab/Parallels/BlockingQueue.cs Wed Oct 04 15:44:47 2017 +0300 @@ -5,13 +5,13 @@ public class BlockingQueue<T> : AsyncQueue<T> { readonly object m_lock = new object(); - public override void Enqueue(T value) { + public void EnqueuePulse(T value) { base.Enqueue(value); lock (m_lock) Monitor.Pulse(m_lock); } - public override void EnqueueRange(T[] data, int offset, int length) { + public void EnqueueRangePulse(T[] data, int offset, int length) { base.EnqueueRange(data, offset, length); if (length > 1) lock (m_lock)