X-Git-Url: http://demsky.eecs.uci.edu/git/?p=model-checker-benchmarks.git;a=blobdiff_plain;f=queue%2Fg_blocking_queue_impl.h;fp=queue%2Fg_blocking_queue_impl.h;h=0000000000000000000000000000000000000000;hp=7312814bd0ede1c52ec497238b41e837cc2c113b;hb=819715e1278ec7efecc81cf1d62c298eb396c730;hpb=69d1985b2a13f7f53fd717c094641a795b9c0410 diff --git a/queue/g_blocking_queue_impl.h b/queue/g_blocking_queue_impl.h deleted file mode 100644 index 7312814..0000000 --- a/queue/g_blocking_queue_impl.h +++ /dev/null @@ -1,224 +0,0 @@ -// ============================================================================ -// Copyright (c) 2009-2010 Faustino Frechilla -// All rights reserved. -// -// Redistribution and use in source and binary forms, with or without -// modification, are permitted provided that the following conditions are met: -// -// 1. Redistributions of source code must retain the above copyright notice, -// this list of conditions and the following disclaimer. -// 2. Redistributions in binary form must reproduce the above copyright -// notice, this list of conditions and the following disclaimer in the -// documentation and/or other materials provided with the distribution. -// 3. The name of the author may not be used to endorse or promote products -// derived from this software without specific prior written permission. -// -// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" -// AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE -// IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE -// ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE -// LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR -// CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF -// SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS -// INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN -// CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) -// ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE -// POSSIBILITY OF SUCH DAMAGE. -// -/// @file q_blocking_queue_impl.h -/// @brief Implementation of a thread-safe queue based on glib system calls -/// It internally contains a std::queue which is protected from concurrent -/// access by glib mutextes and conditional variables -/// -/// @author Faustino Frechilla -/// @history -/// Ref Who When What -/// Faustino Frechilla 04-May-2009 Original development (based on pthreads) -/// Faustino Frechilla 19-May-2010 Ported to glib. Removed pthread dependency -/// @endhistory -/// -// ============================================================================ - -#ifndef _GBLOCKINGQUEUEIMPL_H_ -#define _GBLOCKINGQUEUEIMPL_H_ - -#include - -#define NANOSECONDS_PER_SECOND 1000000000 - -template -BlockingQueue::BlockingQueue(std::size_t a_maxSize) : - m_maximumSize(a_maxSize) -{ - if (!g_thread_supported ()) - { - // glib thread system hasn't been initialized yet - g_thread_init(NULL); - } - - m_mutex = g_mutex_new(); - m_cond = g_cond_new(); - - assert(m_mutex != NULL); - assert(m_cond != NULL); -} - -template -BlockingQueue::~BlockingQueue() -{ - g_cond_free(m_cond); - g_mutex_free(m_mutex); -} - -template -bool BlockingQueue::IsEmpty() -{ - bool rv; - - g_mutex_lock(m_mutex); - rv = m_theQueue.empty(); - g_mutex_unlock(m_mutex); - - return rv; -} - -template -bool BlockingQueue::Push(const T &a_elem) -{ - g_mutex_lock(m_mutex); - - while (m_theQueue.size() >= m_maximumSize) - { - g_cond_wait(m_cond, m_mutex); - } - - bool queueEmpty = m_theQueue.empty(); - - m_theQueue.push(a_elem); - - if (queueEmpty) - { - // wake up threads waiting for stuff - g_cond_broadcast(m_cond); - } - - g_mutex_unlock(m_mutex); - - return true; -} - -template -bool BlockingQueue::TryPush(const T &a_elem) -{ - g_mutex_lock(m_mutex); - - bool rv = false; - bool queueEmpty = m_theQueue.empty(); - - if (m_theQueue.size() < m_maximumSize) - { - m_theQueue.push(a_elem); - rv = true; - } - - if (queueEmpty) - { - // wake up threads waiting for stuff - g_cond_broadcast(m_cond); - } - - g_mutex_unlock(m_mutex); - - return rv; -} - -template -void BlockingQueue::Pop(T &out_data) -{ - g_mutex_lock(m_mutex); - - while (m_theQueue.empty()) - { - g_cond_wait(m_cond, m_mutex); - } - - bool queueFull = (m_theQueue.size() >= m_maximumSize) ? true : false; - - out_data = m_theQueue.front(); - m_theQueue.pop(); - - if (queueFull) - { - // wake up threads waiting for stuff - g_cond_broadcast(m_cond); - } - - g_mutex_unlock(m_mutex); -} - -template -bool BlockingQueue::TryPop(T &out_data) -{ - g_mutex_lock(m_mutex); - - bool rv = false; - if (!m_theQueue.empty()) - { - bool queueFull = (m_theQueue.size() >= m_maximumSize) ? true : false; - - out_data = m_theQueue.front(); - m_theQueue.pop(); - - if (queueFull) - { - // wake up threads waiting for stuff - g_cond_broadcast(m_cond); - } - - rv = true; - } - - g_mutex_unlock(m_mutex); - - return rv; -} - -template -bool BlockingQueue::TimedWaitPop(T &data, glong microsecs) -{ - g_mutex_lock(m_mutex); - - // adding microsecs to now - GTimeVal abs_time; - g_get_current_time(&abs_time); - g_time_val_add(&abs_time, microsecs); - - gboolean retcode = TRUE; - while (m_theQueue.empty() && (retcode != FALSE)) - { - // Returns TRUE if cond was signalled, or FALSE on timeout - retcode = g_cond_timed_wait(m_cond, m_mutex, &abs_time); - } - - bool rv = false; - bool queueFull = (m_theQueue.size() >= m_maximumSize) ? true : false; - if (retcode != FALSE) - { - data = m_theQueue.front(); - m_theQueue.pop(); - - rv = true; - } - - if (rv && queueFull) - { - // wake up threads waiting for stuff - g_cond_broadcast(m_cond); - } - - g_mutex_unlock(m_mutex); - - return rv; -} - -#endif /* _GBLOCKINGQUEUEIMPL_H_ */