电子技术论坛_中国专业的电子工程师学习交流社区-中电网技术论坛

标题: 消息队列的设计与实现（2） [打印本页]

作者: yuyang911220 时间: 2015-6-28 17:08 标题: 消息队列的设计与实现（2）

写操作如上面的流程图介绍，写操作主要包括如下几步：- 获取锁；

判断队列是否已满；
若没满，将数据写入 write_pos 处，将 write_pos 增 1，并判断 write_pos 是否越界；
释放锁，并将信号量增 1。

/* lock the message queue */
pthread_mutex_lock (_msg_queue->lock);

/* check if the queue is full. */
if ((_msg_queue->write_pos + 1)% _msg_queue->size == _msg_queue->read_pos) {
/* Message queue is full. */
pthread_mutex_unlock (_msg_queue->lock);
return;
}

/* write a data to write_pos. */
_msg_queue -> msg [write_pos] = *msg;
write_pos ++;

/* check if write_pos if overflow. */
if (_msg_queue->write_pos >= _msg_queue->size)
_msg_queue->write_pos = 0;

/* release lock */
pthread_mutex_unlock (_msg_queue->lock);

sem_post (_msg_queue->wait);

读操作同理，读操作分如下几个步骤：

检查信号量；
获取锁；
判断队列是否为空；
若不为空，则读取 read_ops 处的数据，将 read_ops 增 1，并判断read_pos 是否越界；
并释放锁。

sem_wait (_msg_queue->wait);

/* lock the message queue */
pthread_mutex_lock (_msg_queue->lock);

/* check if queue is empty */
if (_msg_queue->read_pos != _msg_queue->write_pos) {
msg = _msg_queue->msg + _msg_queue->read_pos;

/* read a data and check if read_pos is overflow */
_msg_queue->read_pos ++;
if (_msg_queue->read_pos >= _msg_queue->size)
_msg_queue->read_pos = 0;

return;
}

/* release lock*/
pthread_mutex_unlock (_msg_queue->lock);

问题

本文采用的环形队列是固定长度的，还可进一步改进，设计成可变长度的环形队列；
本文的消息队列是“先进先出”原则，没有考虑带优先级的消息，但这种场合是存在的；
本文重点介绍了消息队列的原理和实现，对于一个 GUI 程序来讲，还需要一个消息循环与消息队列一起工作，消息循环将单独总结

欢迎光临电子技术论坛_中国专业的电子工程师学习交流社区-中电网技术论坛 (http://bbs.eccn.com/)