操作系统实验报告_进程与进程通信(8)

上海交通大学网络教育学院--计算机专业--操作系统作业---操作系统实验报告_进程与进程通信

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);

百度搜索“77cn”或“免费范文网”即可找到本站免费阅读全部范文。收藏本站方便下次阅读，免费范文网，提供经典小说综合文库操作系统实验报告_进程与进程通信(8)在线全文阅读。