22 #include <plugin/slave/queue_thread.h>
23 #include <drizzled/internal/my_pthread.h>
24 #include <boost/thread.hpp>
26 using namespace drizzled;
30 void QueueThread::run()
32 boost::posix_time::seconds duration(getSleepInterval());
35 internal::my_thread_init();
44 boost::this_thread::disable_interruption di;
56 boost::this_thread::sleep(duration);
58 catch (boost::thread_interrupted &)