gistfile1.hpp

class EventQueue {
  Queue<nsIRunnable> mQueue;
  PRBool mWaiting;
  mozilla::Monitor mRarelyUsedMonitor;
public:
  EventQueue()
    : mQueue()
    , mWaiting(0)
    , mRarelyUsedMonitor("EventQueue::mRarelyUsedMonitor")
  {}
  PRBool GetEvent(PRBool mayWait, nsIRunnable** result) {
    if (!mQueue.dequeue(*result)) {
      if (!mayWait)
        return PR_FALSE;
      mozilla::MonitorAutoEnter mon(mRarelyUsedMonitor);
      while (!mQueue.dequeue(*result)) {
        mWaiting = PR_TRUE;
        mon.Wait();
      }
    }
    return PR_TRUE;
  }
  void PutEvent(nsIRunnable* event) {
    NS_IF_ADDREF(event);
    mQueue.enqueue(event);
    if (mWaiting) {
      mozilla::MonitorAutoEnter mon(mRarelyUsedMonitor);
      mWaiting = PR_FALSE;
      mon.NotifyAll();
    }
  }
};