You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
117 lines
2.2 KiB
117 lines
2.2 KiB
/* ============================================================
|
|
*
|
|
* This file is a part of digiKam project
|
|
* http://www.digikam.org
|
|
*
|
|
* Date : 2004-09-30
|
|
* Description : camera download multi-threading handler.
|
|
*
|
|
* Copyright (C) 2004 by Renchi Raju <renchi@pooh.tam.uiuc.edu>
|
|
|
|
* 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 COMMAND_QUEUE_H
|
|
#define COMMAND_QUEUE_H
|
|
|
|
// TQt includes.
|
|
|
|
#include <tqptrqueue.h>
|
|
#include <tqmutex.h>
|
|
|
|
namespace Digikam
|
|
{
|
|
|
|
template<class Type> class MTQueue
|
|
{
|
|
|
|
public:
|
|
|
|
MTQueue()
|
|
{
|
|
queue_.setAutoDelete(true);
|
|
}
|
|
|
|
~MTQueue()
|
|
{
|
|
flush();
|
|
}
|
|
|
|
bool isEmpty()
|
|
{
|
|
mutex_.lock();
|
|
bool empty = queue_.isEmpty();
|
|
mutex_.unlock();
|
|
return empty;
|
|
}
|
|
|
|
void flush()
|
|
{
|
|
mutex_.lock();
|
|
queue_.clear();
|
|
mutex_.unlock();
|
|
}
|
|
|
|
void enqueue(Type * t)
|
|
{
|
|
mutex_.lock();
|
|
queue_.enqueue(t);
|
|
mutex_.unlock();
|
|
}
|
|
|
|
Type * dequeue()
|
|
{
|
|
mutex_.lock();
|
|
Type * i = queue_.dequeue();
|
|
mutex_.unlock();
|
|
return i;
|
|
}
|
|
|
|
Type * head(bool lock=true)
|
|
{
|
|
if (lock)
|
|
mutex_.lock();
|
|
Type * i = queue_.head();
|
|
if (lock)
|
|
mutex_.unlock();
|
|
return i;
|
|
}
|
|
|
|
int count()
|
|
{
|
|
mutex_.lock();
|
|
int c = queue_.count();
|
|
mutex_.unlock();
|
|
return c;
|
|
}
|
|
|
|
void lock()
|
|
{
|
|
mutex_.lock();
|
|
}
|
|
|
|
void unlock()
|
|
{
|
|
mutex_.unlock();
|
|
}
|
|
|
|
private:
|
|
|
|
TQPtrQueue<Type> queue_;
|
|
TQMutex mutex_;
|
|
};
|
|
|
|
} // namespace Digikam
|
|
|
|
#endif // COMMAND_QUEUE_H
|