【正文】 。 break。 free_all()。 swtch()。 TL = 1。/*按任意鍵繼續(xù) !\n)。 /*線程 receiver 調(diào)用 receive 接收 sender 發(fā)來的消息 */ printf(\t Here, message buffer has 5 units.\n)。sender\39。receiver\39。\n)。\n)。 call primitive(send) to send 10 messages to \39。/*線程間的通信 : */ printf(\t Thread \39。 clrscr()。 create(receiver, (codeptr) receiver, 1024)。 n = 0。 break。 free_all()。 swtch()。 swtch()。 TL=1。 getch()。 create(f4, (codeptr) f4, 1024)。 print_state()。 case 3: print_state()。 getch()。 print_state()。 swtch()。 getch()。 setvect(8,new_int8)。 /*請設(shè)置時間片的大小 (單位為 1/ 秒 )*/ scanf(%d, amp。 /*而線程 f2 不斷輸出字母 b,共 30 次。b\39。 60 times, \n)。 /*時間片輪轉(zhuǎn)方式下兩個線程的并發(fā)執(zhí)行 */ printf(\t Thread f1 continuous output \39。 printf(\t RoundRobin in two threads39。 getch()。 create(f2, (codeptr) f2, 1024)。 print_state()。 case 2: print_state()。 getch()。 getch()。 swtch()。 /*按任意鍵繼續(xù) */ getch()。 30 times.\n)。 /*其中線程 f1 不斷輸出字母 a,共 60 次 */ printf(\t Thread f2 continuous output \39。a\39。 concurrent running: \n)。 clrscr()。 print_state()。 getch()。 create(f1, (codeptr) f1, 1024)。 } while (select 1 || select 4)。 scanf(%d, amp。 printf(| and receive massage |\n)。 printf(| robin |\n)。 printf(|_______________________________________________________|\n)。 printf( ________________________________________________________\n)。 select。 now = 0。 strcpy(tcb[0].name, main)。 InitTcb()。/* 發(fā)送確認(rèn)消息 */ } void main(){ int select=1。 } strcpy(b, ok)。 j++) putchar(b[j])。/* 已接收到消息 */ for (j = 0。 while ((size = receive(sender, b)) == 1) 。 i 10。 char b[10]。 } else printf(Committed,Communication is finished!\n)。 if (strcmp(a, ok) != 0) { printf(Not be mitted,Message should be resended!\n)。 n++。 send(receiver, a, strlen(a))。+n 。 a[7] = 39。 i 10。 char a[10]。mutex)。)。 putchar(39。k1000。j1000。)。 putchar(39。i++){ p(amp。 for(i=0。mutex)。)。 putchar(39。k1000。j1000。)。 putchar(39。i++){ p(amp。 for(i=0。k++)。j++) for(k=0。 /*延時 */ for(j=0。b39。i30。 } } void f2(void) { int i,j,k。k10000。j10000。)。i++){ putchar(39。 for(i=0。 tcb[i].stack = NULL。 tcb[i].state = FINISHED。 i++) { if (tcb[i].stack) { tcb[i].name[0] = 39。 for (i = 1。 return (size)。sfb)。mutex)。freebuf, buff)。mutex)。 i++, b++) *b = bufftext[i]。 for (i = 0。 return (1)。tcb[now].sm)。tcb[now].mutex)。(tcb[now].mq), id)。tcb[now].mutex)。tcb[now].sm)。 return (0)。 break。 i NTCB。 disable()。 } int receive(char *sender, char *b) { int i, size, id = 1。 freebuf = amp。buf[i + 1]。 i NBUF 1。 } void init_buf(void) { int i。 enable()。 v(amp。 v(amp。 insert(amp。 /*將消息緩沖區(qū)插入到接收者線程的消息隊列末尾 */ p(amp。ibuffsize。 buffnext=NULL。 /*填寫消息緩沖區(qū)各項信息 */ buffsender=now。 v(amp。mutex)。sfb)。 return。 } } if(id==1) { printf(Error: Receiver not exist!\n)。i++){ /*如果接收者線程不存在，則不發(fā)送，立即返回 */ if(strcmp(receiver,tcb[i].name)==0){ id=i。 for(i=0。 int i,id=1。 } else { return (NULL)。 buffnext = NULL。 if (q == NULL) *mq = buffnext。 p = pnext。amp。 p = *mq。 } struct buffer