6 #include <boost/thread.hpp>
9 static volatile bool finish =
false;
30 boost::shared_ptr<void> ptr;
31 ptr =
queue->pop_front();
32 const int count = ptr.use_count();
34 std::cerr <<
"NonBlockDelete " << count <<
" > 1 "
35 << ptr.get() << std::endl;
61 queue->thread->join();
69 return the_instance.
queue->size();
78 instance().push_back(ptr);
87 queue->push_back(ptr);
94 while (the_instance.
queue->size())
96 boost::shared_ptr<void> ptr
97 = the_instance.
queue->pop_front_non_block();
99 boost::thread::yield();
106 if (the_instance.
queue->size() == 0)
108 boost::shared_ptr<void> ptr
109 = the_instance.
queue->pop_front_non_block();