FOS的消息队列管理

什么是消息队列

消息队列的使用

消息队列的设计

什么消息队列

想象一个场景，线程a断断续续的向线程b发送数据，线程b要根据接送到的数据去解析做逻辑处理，但是b线程是优先级比较低的任务，不会去实时处理数据，造成丢数据。如何解决这种问题，可以设想有个大buffer作为缓冲区，线程a发送的数据送到buffer，线程b从buffer提取数据，这样就可以解决线程a发送的数据丢失问题。如何管理buffer，消息队列就是一套管理buffer的软件。

消息队列的使用

msg_queue_create(QUEUE * entry, U32 length, U8 * name)

初始化消息队列

msg_put(QUEUE * entry, MSG * msg, U8 method)

把消息放入消息队列，method有两种选择，一种是先入先出，一种是后入先出。

void msg_get(QUEUE * entry, void *buffer)

取出消息。

void msg_queue_delete(QUEUE *entry)

销毁消息队列，释放内存。

消息队列的设计

fos的消息队列是由底层的双向链表串起来使用，消息可以是int、string，插入队列可以选择FIFO或是LIFO模式, 任务发送消息，如果消息队列满了，那么任务会主动被挂起阻塞，等待其他任务获取消息以后才会被调度。任务取消息，如果消息队列是空的，那么任务会被挂起，等待其他任务发送信息给消息队列才可以被调度。

具体代码：https://github.com/dreamflyforever/fos/blob/fos-linux-gcc/kernel/queue.c