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)