在一个单独的线程 ( std::thread
) 中,我有一个等待的事件循环xcb_wait_for_event
。当程序退出时,我想通过中断很好地关闭事情(我有一个设置线程局部变量的解决方案,循环中的检查点抛出异常),然后将我的事件线程加入主线程。问题是xcb_wait_for_event
;我需要一种方法来提早返回,或者我需要一个替代函数。
任何人都可以提出解决方案吗?谢谢你的帮助!
在一个单独的线程 ( std::thread
) 中,我有一个等待的事件循环xcb_wait_for_event
。当程序退出时,我想通过中断很好地关闭事情(我有一个设置线程局部变量的解决方案,循环中的检查点抛出异常),然后将我的事件线程加入主线程。问题是xcb_wait_for_event
;我需要一种方法来提早返回,或者我需要一个替代函数。
任何人都可以提出解决方案吗?谢谢你的帮助!
我相信我已经想出了一个合适的解决方案。我已替换xcb_wait_for_event
为以下功能:
xcb_generic_event_t *WaitForEvent(xcb_connection_t *XConnection)
{
xcb_generic_event_t *Event = nullptr;
int XCBFileDescriptor = xcb_get_file_descriptor(XConnection);
fd_set FileDescriptors;
struct timespec Timeout = { 0, 250000000 }; // Check for interruptions every 0.25 seconds
while (true)
{
interruptible<std::thread>::check();
FD_ZERO(&FileDescriptors);
FD_SET(XCBFileDescriptor, &FileDescriptors);
if (pselect(XCBFileDescriptor + 1, &FileDescriptors, nullptr, nullptr, &Timeout, nullptr) > 0)
{
if ((Event = xcb_poll_for_event(XConnection)))
break;
}
}
interruptible<std::thread>::check();
return Event;
}
使用xcb_get_file_descriptor
,我可以pselect
用来等待直到有新事件,或者直到发生指定的超时。这种方法产生的额外 CPU 成本可以忽略不计,固定在 0.0%(在这个 i7 上)。唯一的“缺点”是必须等待最多 0.25 秒来检查中断,我确信可以安全地降低限制。
一个更简洁的方法是做这样的事情(代码片段是从我目前正在处理的一些代码中提取的):
void QXcbEventQueue::sendCloseConnectionEvent() const {
// A hack to close XCB connection. Apparently XCB does not have any APIs for this?
xcb_client_message_event_t event;
memset(&event, 0, sizeof(event));
event.response_type = XCB_CLIENT_MESSAGE;
event.format = 32;
event.sequence = 0;
event.window = m_connection->clientLeader();
event.type = m_connection->atom(QXcbAtom::_QT_CLOSE_CONNECTION);
event.data.data32[0] = 0;
xcb_connection_t *c = m_connection->xcb_connection();
xcb_send_event(c, false, m_connection->clientLeader(),
XCB_EVENT_MASK_NO_EVENT, reinterpret_cast<const char *>(&event));
xcb_flush(c); }
对于 _QT_CLOSE_CONNECTION 使用您自己的原子来发出退出信号,在我的情况下 clientLeader() 是一些不可见的窗口,它始终存在于我的 X11 连接上。如果您没有任何可用于此目的的不可见窗口,请创建一个 :)
这样,当您看到此特殊事件到达时,您可以使用 xcb_wait_for_event 终止线程。