【发布时间】：2011-05-15 18:02:55
【问题描述】：
我想要一些关于下面列出的 IService 类的反馈。据我所知，这种类型的类与“活动对象”模式有关。如果我错误地使用了任何相关术语，请原谅/更正。基本上这个想法是使用这个活动对象类的类需要提供一个控制一些事件循环的开始和停止方法。这个事件循环可以用while循环或boost asio等来实现。
这个类负责以非阻塞方式启动一个新线程，以便事件可以在新线程中/由新线程处理。它还必须处理所有与清理相关的代码。我首先尝试了一种 OO 方法，其中子类负责覆盖控制事件循环的方法，但清理工作很混乱：在调用类没有手动调用的情况下，在析构函数中调用 stop 方法会导致纯虚函数调用停止方法。模板化的解决方案似乎更干净：
template <typename T>
class IService : private boost::noncopyable
{
typedef boost::shared_ptr<boost::thread> thread_ptr;
public:
IService()
{
}
~IService()
{
/// try stop the service in case it's running
stop();
}
void start()
{
boost::mutex::scoped_lock lock(m_threadMutex);
if (m_pServiceThread && m_pServiceThread->joinable())
{
// already running
return;
}
m_pServiceThread = thread_ptr(new boost::thread(boost::bind(&IService::main, this)));
// need to wait for thread to start: else if destructor is called before thread has started
// Wait for condition to be signaled and then
// try timed wait since the application could deadlock if the thread never starts?
//if (m_startCondition.timed_wait(m_threadMutex, boost::posix_time::milliseconds(getServiceTimeoutMs())))
//{
//}
m_startCondition.wait(m_threadMutex);
// notify main to continue: it's blocked on the same condition var
m_startCondition.notify_one();
}
void stop()
{
// trigger the stopping of the event loop
m_serviceObject.stop();
if (m_pServiceThread)
{
if (m_pServiceThread->joinable())
{
m_pServiceThread->join();
}
// the service is stopped so we can reset the thread
m_pServiceThread.reset();
}
}
private:
/// entry point of thread
void main()
{
boost::mutex::scoped_lock lock(m_threadMutex);
// notify main thread that it can continue
m_startCondition.notify_one();
// Try Dummy wait to allow 1st thread to resume???
m_startCondition.wait(m_threadMutex);
// call template implementation of event loop
m_serviceObject.start();
}
/// Service thread
thread_ptr m_pServiceThread;
/// Thread mutex
mutable boost::mutex m_threadMutex;
/// Condition for signaling start of thread
boost::condition m_startCondition;
/// T must satisfy the implicit service interface and provide a start and a stop method
T m_serviceObject;
};
该类可以按如下方式使用：
class TestObject3
{
public:
TestObject3()
:m_work(m_ioService),
m_timer(m_ioService, boost::posix_time::milliseconds(200))
{
m_timer.async_wait(boost::bind(&TestObject3::doWork, this, boost::asio::placeholders::error));
}
void start()
{
// simple event loop
m_ioService.run();
}
void stop()
{
// signal end of event loop
m_ioService.stop();
}
void doWork(const boost::system::error_code& e)
{
// Do some work here
if (e != boost::asio::error::operation_aborted)
{
m_timer.expires_from_now( boost::posix_time::milliseconds(200) );
m_timer.async_wait(boost::bind(&TestObject3::doWork, this, boost::asio::placeholders::error));
}
}
private:
boost::asio::io_service m_ioService;
boost::asio::io_service::work m_work;
boost::asio::deadline_timer m_timer;
};
现在是我的具体问题：
1) 升压条件变量的使用是否正确？对我来说，这似乎有点小题大做：我想等待线程启动，所以我等待条件变量。然后，一旦新线程在 main 方法中启动，我再次等待相同的条件变量以允许初始线程继续。然后一旦初始线程的start方法退出，新线程就可以继续。这样可以吗？
2) 是否存在操作系统无法成功启动线程的情况？我记得在某处读到过这可能发生。如果可能的话，我宁愿对条件变量进行定时等待（正如在 start 方法中注释掉的那样）？
3) 我知道模板类无法“正确”实现停止方法，即如果事件循环未能停止，代码将阻塞连接（在停止或析构函数中）但我没有办法解决这个问题。我想这取决于类的用户来确保正确实现启动和停止方法？
4) 如果有任何其他设计错误、改进等，我将不胜感激？
谢谢！
【问题讨论】：
标签： c++ boost-thread active-objects