aboutsummaryrefslogtreecommitdiff
path: root/src/shared/Database/SqlDelayThread.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/shared/Database/SqlDelayThread.h')
-rw-r--r--src/shared/Database/SqlDelayThread.h8
1 files changed, 5 insertions, 3 deletions
diff --git a/src/shared/Database/SqlDelayThread.h b/src/shared/Database/SqlDelayThread.h
index 4c77c122f1e..7f534d93237 100644
--- a/src/shared/Database/SqlDelayThread.h
+++ b/src/shared/Database/SqlDelayThread.h
@@ -24,14 +24,16 @@
#include "zthread/Thread.h"
#include "zthread/Runnable.h"
#include "zthread/FastMutex.h"
-#include "zthread/LockedQueue.h"
+#include "zthread/MonitoredQueue.h"
class Database;
class SqlOperation;
+
+
class SqlDelayThread : public ZThread::Runnable
{
- typedef ZThread::LockedQueue<SqlOperation*, ZThread::FastMutex> SqlQueue;
+typedef ZThread::MonitoredQueue<SqlOperation*, ZThread::FastMutex> SqlQueue;
private:
SqlQueue m_sqlQueue; ///< Queue of SQL statements
Database* m_dbEngine; ///< Pointer to used Database engine
@@ -39,7 +41,7 @@ class SqlDelayThread : public ZThread::Runnable
SqlDelayThread();
public:
- SqlDelayThread(Database* db);
+ SqlDelayThread(Database* db,const char* infoString);
///< Put sql statement to delay queue
inline bool Delay(SqlOperation* sql) { m_sqlQueue.add(sql); return true; }