进程线程之间的同步生产者消费者信号量读者写者写者优先

#include <windows.h> #include <stdio.h> #include <string.h> int main(int argc, char* argv[]) { //创建各互斥信号量------------------------------------------------------ HANDLE h_mutexWriterCount,h_mutexReaderCount, h_libAccess,h_writerAccess; h_mutexWriterCount = CreateSemaphore(NULL,1,1, "mutexWriterCount"); h_mutexReaderCount = CreateSemaphore(NULL,1,1, "mutexReaderCount"); h_libAccess = CreateSemaphore(NULL,1,1, "libAccess");; h_writerAccess = CreateSemaphore(NULL,1,1, "writerAccess"); //创建进程共享的字符lib,并初始化未'#'------------------------------------ HANDLE h_lib; h_lib = CreateFileMapping((HANDLE)0xFFFFFFFF,NULL,PAGE_READWRITE,0,sizeof(char),"lib"); if(h_lib == NULL) { printf("Create shared lib failed ...!\n"); exit(1); } char * lib=(char*)MapViewOfFile(h_lib, FILE_MAP_ALL_ACCESS, 0, 0, sizeof(char)); (*lib)= '#'; UnmapViewOfFile(h_lib); //创建进程共享的整形读者计数器readerCount,并初始化未0------------------------------------ HANDLE h_readerCount; h_readerCount = CreateFileMapping((HANDLE)0xFFFFFFFF,NULL,PAGE_READWRITE,0,sizeof(UINT),"readerCount"); if(h_readerCount== NULL) { printf("Create readerCount failed ...!\n"); exit(1); } UINT * readerCount =(UINT *)MapViewOfFile(h_readerCount, FILE_MAP_ALL_ACCESS, 0, 0, sizeof(UINT)); (*readerCount)= 0 ; UnmapViewOfFile(h_readerCount); //创建进程共享的整形写者计数器readerCount,并初始化未0------------------------------------ HANDLE h_writerCount; h_writerCount = CreateFileMapping((HANDLE)0xFFFFFFFF,NULL,PAGE_READWRITE,0,sizeof(UINT),"writerCount"); if(h_readerCount== NULL) { printf("Create writerCount failed ...!\n"); exit(1); } UINT * writerCount =(UINT *)MapViewOfFile(h_readerCount, FILE_MAP_ALL_ACCESS, 0, 0, sizeof(UINT)); (*writerCount)= 0 ; UnmapViewOfFile(h_writerCount); //创建3个读者进程和2个写者进程------------------------------------------- bool succ=false; HANDLE h_p[5]; PROCESS_INFORMATION pi[5]; STARTUPINFO si_r1={sizeof(si_r1)}; succ= CreateProcess("D:\\大三_上\\操作系统\\_experiment2\\_3r&w\\reader\\bin\\Debug\\reader.exe",//读者1 "1", NULL, NULL, FALSE, 0, NULL, NULL, &si_r1, &pi[0]); if(!succ){printf("Create Process 1 failed\n"); exit(1);} STARTUPINFO si_r2={sizeof(si_r2)}; succ= CreateProcess("D:\\大三_上\\操作系统\\_experiment2\\_3r&w\\reader\\bin\\Debug\\reader.exe",//读者2 "2", NULL, NULL, FALSE, 0, NULL, NULL, &si_r2, &pi[1]); if(!succ){printf("Create Process 2 failed\n"); exit(1);} STARTUPINFO si_r3={sizeof(si_r3)}; succ= CreateProcess("D:\\大三_上\\操作系统\\_experiment2\\_3r&w\\reader\\bin\\Debug\\reader.exe",//读者3 "3", NULL, NULL, FALSE, 0, NULL, NULL, &si_r3, &pi[2]); if(!succ){printf("Create Process 3 failed\n"); exit(1);} STARTUPINFO si_w1={sizeof(si_w1)}; succ= CreateProcess("D:\\大三_上\\操作系统\\_experiment2\\_3r&w\\writer\\bin\\Debug\\writer.exe",//写者1 "1", NULL, NULL, FALSE, 0, NULL, NULL, &si_w1, &pi[3]); if(!succ){printf("Create Process 4 failed\n"); exit(1);} STARTUPINFO si_w2={sizeof(si_w2)}; succ= CreateProcess("D:\\大三_上\\操作系统\\_experiment2\\_3r&w\\writer\\bin\\Debug\\writer.exe",//写者2 "2", NULL, NULL, FALSE, 0, NULL, NULL, &si_w2, &pi[4]); if(!succ){printf("Create Process 5 failed\n"); exit(1);} for(int i=0;i<5;i++) h_p[i]=pi[i].hProcess; getchar(); WaitForMultipleObjects(5,h_p,TRUE,INFINITE); //Sleep(1000000); //CloseHandle(h_isWriter); //CloseHandle(h_access); // WaitForMultipleObjects(3, h_preader,TRUE, INFINITE); // WaitForMultipleObjects(2, h_pwriter,TRUE, INFINITE); return 0; }