教你Unix消息隊列的應用

我們以前學習過Unix消息隊列的創建、刪除、發送和接收的知識，今天，我們來學習在線程中Unix消息隊列應用以實現多任務線程間的數據共享的知識，洗大家能夠在Unix的學習上有所收獲。

首先在main主函數中創建Unix消息隊列和線程：//定義全局變量

Int msqueue_record, msqueue_process;   
Void main()   
{   
pthread_t pthreadID1;   
//創建消息隊列，用於線程間通信   
msqueue_record = msqueue_create ( “record”, 200, 200);   
msqueue_process = msqueue_create ( “process”, 200, 200);   
//創建數據采集線程   
pthread_create ( &&pthreadID1, NULL, receiveData, NULL);   
//創建數據處理線程   
pthread_create ( &&pthreadID2, NULL, process, NULL);   
//創建數據記錄線程   
pthread_create ( &&pthreadID1, NULL, record, NULL);   
//等待進程結束   
wait_thread_end( );   
}  

數據采集線程：

void receiveData( )   
{   
int count;   
unsigned char buff[200];   
for(;;) {   
//從數據口采集數據，並將數據放置於buff中   
//wait_data_from_data_port( buff )   
//將數據寫入消息隊列msqueue_record中   
msqueue_send ( msqueue_record, buff, 200 );   
//將數據寫入消息隊列msqueue_process中   
msqueue_send ( msqueue_process, buff, 200 );   
}   
}   

記錄線程函數：

void record ( )   
{   
int num, count;   
unsigned char buffer[200];   
for ( ;; ) {   
count = msqueue_receive ( msg_record, &&buffer, 200 );   
if ( count < 0) {   
perror ( "msgrcv in record");   
continue;   
}   
//將取到的消息進行記錄處理   
//record_message_to_lib();   
}   
}   

數據處理線程函數：

int process( )   
{   
int count;   
unsigned char buffer[200];   
for ( ;; ) {   
count = msqueue_receive ( msg_process, &&buffer, 200 );   
if ( count < 0) {   
perror ( "msgrcv in record");   
continue;   
}   
//將取到的消息進行處理   
//process_message_data()   
}   
}   

在實現多任務系統時，作者曾經做過以下三種實現方法的比較：進程間通信采用IPC機制，線程間通信采用進程通信方式IPC，線程間通信采用基於作者開發的Unix消息隊列。結果表明：利用用戶下的數據區進行線程間通信的速度最快，效率最高，而IPC方式慢。這次，關於Unix消息隊列我們就講解到這裡了。