diff options
Diffstat (limited to 'kipi-plugins/jpeglossless/mtqueue.h')
-rw-r--r-- | kipi-plugins/jpeglossless/mtqueue.h | 89 |
1 files changed, 89 insertions, 0 deletions
diff --git a/kipi-plugins/jpeglossless/mtqueue.h b/kipi-plugins/jpeglossless/mtqueue.h new file mode 100644 index 0000000..209ade5 --- /dev/null +++ b/kipi-plugins/jpeglossless/mtqueue.h @@ -0,0 +1,89 @@ +/* ============================================================ + * + * This file is a part of kipi-plugins project + * http://www.kipi-plugins.org + * + * Date : 2004-11-09 + * Description : Multithread queue description class + * + * Copyright (C) 2004-2005 by Renchi Raju <renchi@pooh.tam.uiuc.edu> + * Copyright (C) 2004-2007 by Marcel Wiesweg <marcel dot wiesweg at gmx dot de> + * Copyright (C) 2006-2007 by Gilles Caulier <caulier dot gilles at gmail dot com> + * + * This program is free software; you can redistribute it + * and/or modify it under the terms of the GNU General + * Public License as published by the Free Software Foundation; + * either version 2, or (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * ============================================================ */ + +#ifndef MTQUEUE_H +#define MTQUEUE_H + +// Qt includes. + +#include <qptrqueue.h> +#include <qmutex.h> + +namespace KIPIJPEGLossLessPlugin +{ + +template<class Type> class MTQueue +{ + +public: + + MTQueue() + { + m_queue.setAutoDelete(true); + } + + ~MTQueue() + { + flush(); + } + + bool isEmpty() + { + m_mutex.lock(); + bool empty = m_queue.isEmpty(); + m_mutex.unlock(); + return empty; + } + + void flush() + { + m_mutex.lock(); + m_queue.clear(); + m_mutex.unlock(); + } + + void enqueue(Type * t) + { + m_mutex.lock(); + m_queue.enqueue(t); + m_mutex.unlock(); + } + + Type * dequeue() + { + m_mutex.lock(); + Type * i = m_queue.dequeue(); + m_mutex.unlock(); + return i; + } + +private: + + QPtrQueue<Type> m_queue; + QMutex m_mutex; +}; + +} // NameSpace KIPIJPEGLossLessPlugin + +#endif // MTQUEUE_H |