生产者消费者模式总结1. 建立两个信号量（g_hFull, g_hEmpty），一个互斥量(g_Mutex),定义最大缓冲区的大小。并设刚开始时缓冲区是空的。 #define MAX_BUFFER_SIZE 1024 HANDLE g_hFull; HANDLE g_hEmpty; HANDLE g_hMutex; g_hFull = CreateSemaphore(NULL, 0, MAX_BUFFER_SIZE, _T(“Full”)); g_hEmpty = CreateSemaphore(NULL, MAX_BUFFER_S...
1. 建立两个信号量（g_hFull, g_hEmpty），一个互斥量(g_Mutex),定义最大缓冲区的大小。并设刚开始时缓冲区是空的。 #define MAX_BUFFER_SIZE 1024 HANDLE g_hFull; HANDLE g_hEmpty; HANDLE g_hMutex; g_hFull = CreateSemaphore(NULL, 0, MAX_BUFFER_SIZE, _T(“Full”)); g_hEmpty = CreateSemaphore(NULL, MAX_BUFFER_SIZE, MAX_BUFFER_SIZE, _T(“Empty”)); g_hMutex = CreateMutex(NULL, FALSE, _T(“Mutex”)) 2. 定义共享缓冲区,当前读写的位置和已经存在的数据的长度 Char pBuffer[MAX_BUFFER_SIZE]; Memset(pBuffer, 0, MAX_BUFFER_SIZE); Int nCurrentReadPosition = 0; Int nCurrentWritePisition = 0; Int nCurrentLength = 0; 3. 生产者操作模式： WaitForSingleObject(g_hEmpty, INFINITE); WaitForSingleObject(g_hMutex, INFINITE); pBuffer[nCurrentWritePosition] = ‘X’;//write nCurrentWritePosition = (nCurrentWritePosition + 1) % MAX_BUFFER_SIZE; nCurrentLength += 1; ReleaseMutex(g_hMutex); ReleaseSemaphore(g_hFull, 1, NULL); 4. 消费者模式： Char ch; WaitForSingleObject(g_hFull, INFINITE); WaitForSingleObject(g_hMutex, INFINITE); ch = pBuffer[nCurrentReadPosition];//Read nCurrentReadPosition = (nCurrentReadPosition + 1) % MAX_BUFFER_SIZE; nCurrentLength -= 1; ReleaseMutex(g_hMutex); ReleaseSemaphore(g_hEmpty);
本文档为【生产者消费者模式总结】，请使用软件OFFICE或WPS软件打开。作品中的文字与图均可以修改和编辑，
图片更改请在作品中右键图片并更换，文字修改请直接点击文字进行修改，也可以新增和删除文档中的内容。
该文档来自用户分享，如有侵权行为请发邮件ishare@vip.sina.com联系网站客服，我们会及时删除。
[版权声明] 本站所有资料为用户分享产生，若发现您的权利被侵害，请联系客服邮件isharekefu@iask.cn，我们尽快处理。
本作品所展示的图片、画像、字体、音乐的版权可能需版权方额外授权，请谨慎使用。
网站提供的党政主题相关内容(国旗、国徽、党徽..)目的在于配合国家政策宣传，仅限个人学习分享使用，禁止用于任何广告和商用目的。
浙公网安备 33021202002483