ACE消息队列 ACE_Message_Queue 入队列，出队列方法（1）

ACE提供的的消息队列 ACE_Message_Queue，作为一个容器类，  不仅可以在其中存储一个具体的对象，也可以存储一个对象的指针。使用起来十分的方便。另外它是一个模板类，在定义的时候可以选择多线程同步工作模式，所以它也可以在线程安全的模式下工作。下边的代码是测试存储对象类为一个stduent类。

// lesson_queue.cpp : Defines the entry point for the console application.

#include "ace/Message_Queue.h"
#include "ace/Synch.h"
#include "string"
#include "iostream"

using namespace std;

class student
{
public:
student(){}
~student(){}
int    number;
char   name[10];
int    english;
void output(int i)
{
if (i == 1)
{
cout<<"insert " << "number=" << number << " name=" << name << " english=" << english <<endl;
}
else
{
cout<<"delete " << "number=" << number << " name=" << name << " english=" << english <<endl;
}
}
};

int main(int argc, char* argv[])
{
ACE_Message_Queue<ACE_MT_SYNCH> mq;

//进入队列
for(int i = 0; i < 10; i++)
{
student stu;
strcpy_s((char*)stu.name, 10, "wangxu");
stu.number = i;
stu.english = i * 10;

int length1 = sizeof(student);
ACE_Message_Block*  mb1 = new ACE_Message_Block(length1, ACE_Message_Block::MB_DATA);

//以下两句话功能一样
//这句简单，一句话完成
mb1->copy((char*)&stu, sizeof(student));

//这种方式需要两句话
//memcpy(mb1->wr_ptr(), (char*)&stu, legnth1);
//mb1->wr_ptr(length1);

int result1 = mq.enqueue(mb1);
stu.output(1);
}

//出队列，用新的容器存储内容
for(int i = 0; i < 10; i++)
{
student stu2;
ACE_Message_Block *mb2;
int result2 = mq.dequeue(mb2);
memcpy((char*)&stu2, mb2->rd_ptr(), mb2->length());
stu2.output(2);
mb2->release();
}

//出队列，用指针方式，类型适配
/*for(int i = 0; i < 10; i++)
{
student* pstu2;
ACE_Message_Block *mb2;
int result2 = mq.dequeue(mb2);
pstu2 = (student*)mb2->base();
pstu2->output(2);
mb2->release();
}*/

system("pause");
return 0;
}