mono/mcs/class/corlib/System.Threading/LockQueue.cs

//
// System.Threading.LockQueue
//
// Author(s):
//  Jackson Harper ([email protected])
//
// (C) 2004 Novell, Inc (http://www.novell.com)
//


using System;

namespace System.Threading {

	// Used for queueing on a reader writer lock
	internal class LockQueue {

		private ReaderWriterLock rwlock;
		private int lockCount = 0;

		public LockQueue (ReaderWriterLock rwlock)
		{
			this.rwlock = rwlock;
		}

		public bool Wait (int timeout)
		{
			bool _lock = false;

			try {
				lock (this) {
					lockCount++;
					Monitor.Exit (rwlock);
					_lock = true;
					return Monitor.Wait (this, timeout);
				}
			} finally {
				if (_lock) {
					Monitor.Enter (rwlock);
					lockCount--;
				}
			}
		}
		
		public bool IsEmpty
		{
			get { lock (this) return (lockCount == 0); }
		}

		public void Pulse ()
		{
			lock (this) Monitor.Pulse (this);
		}

		public void PulseAll ()
		{
			lock (this) Monitor.PulseAll (this);
		}
	}
}