posix無(wú)名信號(hào)量 - 基于xilkernel的嵌入式應(yīng)用程序設(shè)計(jì)

　　信號(hào)量提供高速的任務(wù)間同步和互斥機(jī)制。對(duì)于互斥，信號(hào)量可以上鎖共享資源，使得該共享資源在同一時(shí)刻只有一個(gè)線程所擁有。關(guān)于此信號(hào)量的一些常用函數(shù)如下：

　　intsem_init(sem_t*sem,intpshared,unsignedintvalue);

　　intsem_wait(sem_t*sem);

　　intsem_post(sem_t*sem);

　　sem_init()創(chuàng)建一個(gè)信號(hào)量，并初始化信號(hào)量的值為value;sem_wait()調(diào)用將阻塞進(jìn)程，直到信號(hào)量的值大于0，此函數(shù)返回時(shí)信號(hào)量的值減1;sem_post()是將信號(hào)量的值加1，并發(fā)出信號(hào)喚醒等待的進(jìn)程。

　　信號(hào)量用于同步，一般要初始化為0，等待要同步的任務(wù)阻塞在sem_wait()調(diào)用上。任務(wù)調(diào)用sem_post來(lái)解鎖該信號(hào)量，來(lái)達(dá)到同步。下面一個(gè)例子是用信號(hào)量實(shí)現(xiàn)同步操作的：

　　staticsem_tprotect;

　　void*first_thread(){......

　　sem_init(&protect,1,0);

　　......

　　}

　　void*thread_func1(){......

　　while(1){

　　sem_wait(&protect);

　　......

　　}

　　}

　　void*thread_func2(){......

　　while(1){......

　　if(某種條件成立)sem_post(&protect);

　　}

　　}

　　當(dāng)信號(hào)量用于互斥時(shí)，一般要初始化為一個(gè)大于0的值，就可以讓資源可用。如果信號(hào)量的初始值為1，第一個(gè)上鎖該信號(hào)量的線程會(huì)立即執(zhí)行，后繼的線程將會(huì)阻塞，直到下次信號(hào)量解鎖才會(huì)執(zhí)行。

　　xsi消息隊(duì)列

　　消息隊(duì)列允許長(zhǎng)度可變、數(shù)目可變的消息排隊(duì)。任何任務(wù)或中斷服務(wù)程序可以發(fā)送消息到消息隊(duì)列。任何任務(wù)可從消息隊(duì)列接收消息。關(guān)于此消息隊(duì)列的一些常用函數(shù)如下：

　　intmsgget(key_tkey,intmsgflg)

　　intmsgsnd(intmsqid,constvoid*msgp,size_tmsgsz,intmsgflg)

　　ssize_tmsgrcv(intmsqid,void*msgp,size_tnbytes,longmsgtyp,intmsgflg)

　　msgget()來(lái)創(chuàng)建一個(gè)消息隊(duì)列，key是消息隊(duì)列的標(biāo)識(shí)符，msgflag目前有兩個(gè)選項(xiàng)，ipc_creat和ipc_excl。msgsnd()函數(shù)往隊(duì)列發(fā)送一條消息，msgp是消息緩沖指向的指針，msgsz表示消息的字節(jié)數(shù)。msgrcv()函數(shù)作用是從消息隊(duì)列中讀取消息，把接收到的消息拷貝到msgp指針指向的緩沖區(qū)，nbytes表示緩沖支持的消息字節(jié)數(shù)。發(fā)送和接收消息中的msqid是消息隊(duì)列描述符，用來(lái)標(biāo)識(shí)相關(guān)的消息隊(duì)列。下面是消息隊(duì)列單向通信的簡(jiǎn)單代碼：

　　struct_msg{

　　shorttype;

　　charfirst;

　　charlast;

　　};

　　staticstruct_msgmsg_p;

　　staticstruct_msgmsg_c;

　　staticintmsgid;

　　void*first_thread(){......

　　msgid=msgget(5,ipc_creat|ipc_excl);

　　......

　　}

　　void*consumer()

　　{

　　while(1){

　　msgrcv(msgid,&msg_c,4,0,0);

　　......

　　}

　　}

　　void*producer()

　　{

　　while(1){......

　　msgsnd(msgid,&msg_p,4,0);

　　}

　　}

　　在例子開(kāi)始，建立消息的數(shù)據(jù)結(jié)構(gòu)。在producer()中操作消息的各項(xiàng)數(shù)據(jù)，通過(guò)msgsnd()發(fā)送此消息。在consumer()中，如果消息隊(duì)列里沒(méi)有消息，則msgsnd()阻塞此線程，直到消息隊(duì)列非空時(shí)，msgsnd()才把消息復(fù)制到msg_p指向的數(shù)據(jù)結(jié)構(gòu)中，此時(shí)此線程開(kāi)始執(zhí)行，并可以對(duì)接收到的消息進(jìn)行處理。