diff options
Diffstat (limited to 'src/shared/Database/SqlDelayThread.h')
-rw-r--r-- | src/shared/Database/SqlDelayThread.h | 8 |
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; } |