diff options
| author | n0n4m3 <none@none> | 2010-02-07 08:22:31 +0300 |
|---|---|---|
| committer | n0n4m3 <none@none> | 2010-02-07 08:22:31 +0300 |
| commit | 8676e5056f639c42256b0051d81286ee67af1d77 (patch) | |
| tree | bd6dc47313eddd9030f7b6fdc033a99dfbb36d6f /src/shared/Database/SqlDelayThread.h | |
| parent | bb7222c376785654ff3256e82fda28f4d8be7e98 (diff) | |
Implement async class for database operations for better performance, remove 10ms sleep, fixed some crash on sql execute.
--HG--
branch : trunk
Diffstat (limited to 'src/shared/Database/SqlDelayThread.h')
| -rw-r--r-- | src/shared/Database/SqlDelayThread.h | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/shared/Database/SqlDelayThread.h b/src/shared/Database/SqlDelayThread.h index a4e3aab1c93..15aeecb6bd7 100644 --- a/src/shared/Database/SqlDelayThread.h +++ b/src/shared/Database/SqlDelayThread.h @@ -22,7 +22,7 @@ #define __SQLDELAYTHREAD_H #include "ace/Thread_Mutex.h" -#include "LockedQueue.h" +#include "ace/Activation_Queue.h" #include "Threading.h" class Database; @@ -30,7 +30,7 @@ class SqlOperation; class SqlDelayThread : public ACE_Based::Runnable { - typedef ACE_Based::LockedQueue<SqlOperation*, ACE_Thread_Mutex> SqlQueue; + typedef ACE_Activation_Queue SqlQueue; private: SqlQueue m_sqlQueue; ///< Queue of SQL statements @@ -42,7 +42,7 @@ class SqlDelayThread : public ACE_Based::Runnable SqlDelayThread(Database* db); ///< Put sql statement to delay queue - bool Delay(SqlOperation* sql) { m_sqlQueue.add(sql); return true; } + bool Delay(SqlOperation* sql); virtual void Stop(); ///< Stop event virtual void run(); ///< Main Thread loop |