上海交通大学网络教育学院--计算机专业--操作系统作业---操作系统实验报告_进程与进程通信
43) potherMsgInfo->MsgNum++;
44) lpchar +=
sizeof(_MSGQ_HEADER)+sizeof(char)*potherMsgInfo->MsgSize*potherMsgInfo->WriteIndex;
45) strcpy(lpchar,(char *)buf);
46)
47) if(++potherMsgInfo->WriteIndex == potherMsgInfo->MsgMaxCount)//环形
Queue
48) potherMsgInfo->WriteIndex = 0;
49) ReleaseMutex(openmutex);
50) bRet = TRUE;
51) }
52)
53)
54)
55)
56)
57)
58)
59)
60)
61)
62)
63)
64)
65)
66)
67) //V操作 ReleaseSemaphore(other_SemaphoreReceive,1,NULL); }else if(dRet == WAIT_TIMEOUT) { QMessageBox::information(NULL,tr("提示"), tr("对方邮箱已满，发送失败")); } //CloseHandle(other_hViewBuf); UnmapViewOfFile(ori); CloseHandle(openmutex); CloseHandle(other_hFileMap); CloseHandle(other_SemaphoreSend); CloseHandle(other_SemaphoreReceive); CloseHandle(other_SemaphoreReceive); return bRet; }
5.4.4、
1)
2)
3)
4)
5) Receive()函数实现 BOOL CMsgQ::Receive(LPVOID buf, DWORD waitTime) { LPCVOID ori; char *lpchar; BOOL bRet=FALSE;
6) //打开本地邮箱的发送信号量
7) HANDLE my_SemaphoreSend = OpenSemaphore(SEMAPHORE_ALL_ACCESS,
FALSE, strName[nowProcess][SendEnum]);
8) //打开本地地邮箱的接受信号量
9) HANDLE my_SemaphoreReceive = OpenSemaphore(SEMAPHORE_ALL_ACCESS,
FALSE, strName[nowProcess][ReceiveEnum]);
10)
11) DWORD dRet=WaitForSingleObject(my_SemaphoreReceive, waitTime);