我們以前學習過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消息隊列我們就講解到這裡了。