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

   1 //
   2 // System.Threading.LockQueue
   3 //
   4 // Author(s):
   5 //  Jackson Harper (jackson@ximian.com)
   6 //
   7 // (C) 2004 Novell, Inc (http://www.novell.com)
   8 //
   9
  10 //
  11 // Copyright (C) 2004 Novell, Inc (http://www.novell.com)
  12 //
  13 // Permission is hereby granted, free of charge, to any person obtaining
  14 // a copy of this software and associated documentation files (the
  15 // "Software"), to deal in the Software without restriction, including
  16 // without limitation the rights to use, copy, modify, merge, publish,
  17 // distribute, sublicense, and/or sell copies of the Software, and to
  18 // permit persons to whom the Software is furnished to do so, subject to
  19 // the following conditions:
  20 //
  21 // The above copyright notice and this permission notice shall be
  22 // included in all copies or substantial portions of the Software.
  23 //
  24 // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
  25 // EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
  26 // MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
  27 // NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
  28 // LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
  29 // OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
  30 // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
  31 //
  32
  33
  34 using System;
  35
  36 namespace System.Threading {
  37
  38         // Used for queueing on a reader writer lock
  39         internal class LockQueue {
  40
  41                 private ReaderWriterLock rwlock;
  42                 private int lockCount = 0;
  43
  44                 public LockQueue (ReaderWriterLock rwlock)
  45                 {
  46                         this.rwlock = rwlock;
  47                 }
  48
  49                 public bool Wait (int timeout)
  50                 {
  51                         bool _lock = false;
  52
  53                         try {
  54                                 lock (this) {
  55                                         lockCount++;
  56                                         Monitor.Exit (rwlock);
  57                                         _lock = true;
  58                                         return Monitor.Wait (this, timeout);
  59                                 }
  60                         } finally {
  61                                 if (_lock) {
  62                                         Monitor.Enter (rwlock);
  63                                         lockCount--;
  64                                 }
  65                         }
  66                 }
  67
  68                 public bool IsEmpty
  69                 {
  70                         get { lock (this) return (lockCount == 0); }
  71                 }
  72
  73                 public void Pulse ()
  74                 {
  75                         lock (this) Monitor.Pulse (this);
  76                 }
  77
  78                 public void PulseAll ()
  79                 {
  80                         lock (this) Monitor.PulseAll (this);
  81                 }
  82         }
  83 }
  84