信號量提供高速的任務(wù)間同步和互斥機(jī)制。對于互斥,信號量可以上鎖共享資源,使得該共享資源在同一時(shí)刻只有一個(gè)線程所擁有。關(guān)于此信號量的一些常用函數(shù)如下:
intsem_init(sem_t*sem,intpshared,unsignedintvalue);
intsem_wait(sem_t*sem);
intsem_post(sem_t*sem);
sem_init()創(chuàng)建一個(gè)信號量,并初始化信號量的值為value;sem_wait()調(diào)用將阻塞進(jìn)程,直到信號量的值大于0,此函數(shù)返回時(shí)信號量的值減1;sem_post()是將信號量的值加1,并發(fā)出信號喚醒等待的進(jìn)程。
信號量用于同步,一般要初始化為0,等待要同步的任務(wù)阻塞在sem_wait()調(diào)用上。任務(wù)調(diào)用sem_post來解鎖該信號量,來達(dá)到同步。下面一個(gè)例子是用信號量實(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)信號量用于互斥時(shí),一般要初始化為一個(gè)大于0的值,就可以讓資源可用。如果信號量的初始值為1,第一個(gè)上鎖該信號量的線程會立即執(zhí)行,后繼的線程將會阻塞,直到下次信號量解鎖才會執(zhí)行。
xsi消息隊(duì)列
消息隊(duì)列允許長度可變、數(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()來創(chuàng)建一個(gè)消息隊(duì)列,key是消息隊(duì)列的標(biāo)識符,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ì)列描述符,用來標(biāo)識相關(guān)的消息隊(duì)列。下面是消息隊(duì)列單向通信的簡單代碼:
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);
}
}
在例子開始,建立消息的數(shù)據(jù)結(jié)構(gòu)。在producer()中操作消息的各項(xiàng)數(shù)據(jù),通過msgsnd()發(fā)送此消息。在consumer()中,如果消息隊(duì)列里沒有消息,則msgsnd()阻塞此線程,直到消息隊(duì)列非空時(shí),msgsnd()才把消息復(fù)制到msg_p指向的數(shù)據(jù)結(jié)構(gòu)中,此時(shí)此線程開始執(zhí)行,并可以對接收到的消息進(jìn)行處理。
評論