---

thread_mutex.H

Go to the documentation of this file.

/*
 * Copyright 2000, Brown University, Providence, RI.
 * 
 *                         All Rights Reserved
 * 
 * Permission to use, copy, modify, and distribute this software and its
 * documentation for any purpose other than its incorporation into a
 * commercial product is hereby granted without fee, provided that the
 * above copyright notice appear in all copies and that both that
 * copyright notice and this permission notice appear in supporting
 * documentation, and that the name of Brown University not be used in
 * advertising or publicity pertaining to distribution of the software
 * without specific, written prior permission.
 * 
 * BROWN UNIVERSITY DISCLAIMS ALL WARRANTIES WITH REGARD TO THIS SOFTWARE,
 * INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR ANY
 * PARTICULAR PURPOSE.  IN NO EVENT SHALL BROWN UNIVERSITY BE LIABLE FOR
 * ANY SPECIAL, INDIRECT OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
 * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
 * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
 * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
 */

#ifndef _JOT_STD_THREAD_MUTEX_H
#define _JOT_STD_THREAD_MUTEX_H
// This file should contain generalized thread support, but for now
// it's just a pthread implmentation of a thread syncronization primitive.

#ifdef USE_PTHREAD
#include <pthread.h>
class ThreadMutex {
   public:
      ThreadMutex() { pthread_mutex_init(&_mtx, 0); }
     ~ThreadMutex() { pthread_mutex_destroy(&_mtx); }
      void lock()   { pthread_mutex_lock(&_mtx);    }
      void unlock() { pthread_mutex_unlock(&_mtx);  }
   protected:
      pthread_mutex_t _mtx;
};
#else
class ThreadMutex {
   public:
      ThreadMutex() { }
     ~ThreadMutex() { }
      void lock()   { }
      void unlock() { }
};
#endif

class CriticalSection {
   public:
      CriticalSection(ThreadMutex *mutex) : _mutex(mutex) { _mutex->lock(); }
      ~CriticalSection() { _mutex->unlock(); }
   protected:
      ThreadMutex *_mutex;
};
#endif

---