如何使用boostsio_service.post()执行函数并使用数组或指针作为参数

How can I execute a function with boosts io_service.post() and use an array or pointer as parameter?

本文关键字:数组 指针 参数 函数 boostsio 何使用 service post 执行      更新时间:2023-10-16

当我试图构建一个程序时,它可以用boostsasync_write传输数据块/数组,我可能遇到了线程问题:

这就是我想要执行的:

write(unsigned char *pMsg, unsigned short nMsgLen){
io_service_.post(boost::bind(&m_client::write_buf, this, pMsg, nMsgLen));
}
write_buf(unsigned char *pMsg, unsigned short nMsgLen){
boost::asio::async_write(target,
boost::asio::buffer(pMsg, nMsgLen),
boost::bind(&m_client::write_buf_compl,
this,
boost::asio::placeholders::error));
}

它确实编译了,但当调用write_buf时,pMsg没有正确的内容,我认为这是因为它不是在同一个线程内调用的。

那么,我如何调整这个构造以将数组作为参数进行传递呢?!

你似乎很清楚你的问题在哪里。快速解决方法是通过复制其内容来传递缓冲区:

void write(unsigned char *pMsg, unsigned short nMsgLen) {
// TODO: Take care of exception safety...
char *pMsgCopy = (char *)malloc(nMsgLen);
memcpy(pMsgCopy, pMsg, nMsgLen);
io_service_.post(boost::bind(&m_client::write_buf, this,
pMsgCopy, nMsgLen));
}
void write_buf(unsigned char *pMsg, unsigned short nMsgLen)
{
// Achtung! Don't forget to free memory in complection callback.
boost::asio::async_write(target,
boost::asio::buffer(pMsg, nMsgLen),
boost::bind(&m_client::write_buf_compl,
this,
boost::asio::placeholders::error));
}
void write_buf_compl(...)
{
free(pMsg);
}

如果您热衷于效率,那么您可以通过让write()的调用方首先提供动态分配的缓冲区来避免复制。但如果你真的对性能着迷,那么我建议你不要使用Boost.ASIO。但那是另一回事。