我正在使用mqueue在线程之间进行交流,并且我遇到了问题。
mq_send
和mq_receive
以char*
作为对象的参数。
我以以下方式使用它们。
foo* foo = new foo();
foo->set_id(3);
mq_send(myQueue, (char*)foo, 1024, 1);
然后
char* buffer;
while(true)
{
ssize_t bytes_read;
bytes_read = mq_receive(myQueue, buffer, 1024, NULL);
foo* foo = (foo*) buffer;
foo->get_id(); //equals 3
//Send the object to another queue
mq_send(myOtherQueue, buffer, 1024, 1);
}
到目前为止很好。
问题在这里
char* buffer;
while(true)
{
ssize_t bytes_read;
bytes_read = mq_receive(myOtherQueue, buffer, 1024, NULL);
foo* foo = (foo*) buffer;
foo->get_id(); //equals garbage 323234234
}
第二次我投射缓冲区,我会垃圾。我读了有关static_cast
和dynamic_cast
的信息,但找不到问题。
怎么了?
我在这里看到两个问题。首先,您的foo TriviallyCopyable
?
第二,
char* buffer;
bytes_read = mq_receive(myOtherQueue, buffer, 1024, NULL);
我看不到buffer
的任何分配。