template<typename T>
class CThreadSafeList
{
public:
CThreadSafeList() {}
~CThreadSafeList()
{
if (!list_.empty())
{
list_.clear();
}
}
void push_back(const T &pt)
{
boost::mutex::scoped_lock oLock(mutex_);
list_.push_back(pt);
}
bool pop_front(T &pt)
{
boost::mutex::scoped_lock oLock(mutex_);
if (list_.size() > 0)
{
pt = list_.front();
list_.pop_front();
return true;
}
return false;
}
void erase(T &Object)
{
boost::mutex::scoped_lock oLock(mutex_);
list_.remove(Object);
}
void clear()
{
boost::mutex::scoped_lock oLock(mutex_);
if (!list_.empty())
{
list_.clear();
}
return;
}
int size()
{
boost::mutex::scoped_lock oLock(mutex_);
return list_.size();
}
bool empty()
{
boost::mutex::scoped_lock oLock(mutex_);
return list_.empty();
}
private:
std::list<T> list_;
boost::mutex mutex_;
};
Kaedei
10 years, 6 months ago
