v.rar_影院售票

#include<iostream> using namespace std; char Seats[101][100]; void B(int line,int start,int end); void R(int line,int start,int end); void F(int line,int start,int end); int main() { char Operation; int i,j,line,start,end; for(i=0;i<101;i++) for(j=0;j<100;j++) Seats[i][j]='='; while(cin>>Operation) { switch(Operation) { case 'B': cin>>line>>start>>end; B(line,start,end); break; case 'R': cin>>line>>start>>end; R(line,start,end); break; case 'F': cin>>line>>start>>end; F(line,start,end); break; case 'E': return 0; } } return 0; } void B(int line,int start,int end) { for(int i=start-1;i<end;i+=2) Seats[line-1][i]='X'; } void R(int line,int start,int end) { for(int i=start-1;i<end;i+=2) Seats[line-1][i]='='; } void F(int line,int start,int end) { for(int i=start-1;i<end;i+=2) cout<<Seats[line-1][i]; cout<<endl; } #include "stdafx.h" //包含头文件以支持多线程 #include "windows.h" #include "stdio.h" //用于标志所有的子线程是否结束 //每次子线程结束后，此值便加1。 static long ThreadCompleted = 0; //互斥量 HANDLE mutex; //信号量，用于生产者通知消费者 HANDLE full; //信号量，用于消费者通知生产者 HANDLE empty; //信号量，当所有的子线程结束后，通知主线程，可以结束。 HANDLE evtTerminate; //生产标志 #define p_item 1 //消费标志 #define c_item 0 //哨兵 #define END 3 //缓冲区最大长度 const int max_buf_size=4; const int cur_size=3; //缓冲区定义 int BUFFER[max_buf_size]; //放消息指针 int in=0; //取消息指针 int out=0; int front=0; int tail=0; int sleep_time=1000; //线程函数的标准格式 unsigned long __stdcall p_Thread(void *theBuf); unsigned long __stdcall c_Thread(void *theBuf); //打印缓冲区内容 void PrintBuf(int buf[],int buf_size); int main(int argc, char* argv[]) { //初始化缓冲区 unsigned long TID1, TID2; for(int i=0;i<cur_size;i++) BUFFER[i]=0; //互斥量和信号量的创建，函数用法可查看MSDN mutex=CreateMutex(NULL,false,"mutex"); full=CreateSemaphore(NULL,0,1,"full"); empty=CreateSemaphore(NULL,max_buf_size,max_buf_size,"empty"); evtTerminate = CreateEvent(NULL, FALSE, FALSE, "Terminate"); //创建一个生产者线程和消费者线程。作为本程序的扩展，你可以增加线程的数目 CreateThread(NULL,0,p_Thread,BUFFER,NULL,&TID1); CreateThread(NULL,0,c_Thread,BUFFER,NULL,&TID2); //等待各子线程的结束 WaitForSingleObject(evtTerminate, INFINITE); return 0; } //生产者线程函数 unsigned long __stdcall p_Thread(void *theBuf) { while(true) { Sleep(sleep_time); //可以不要此函数，只是为了模拟缓冲区满的情况 if((front+1)%max_buf_size==tail) { printf("The buffer is full!And the product thread is blocked!\n"); sleep_time+=3000; } WaitForSingleObject(empty,INFINITE);//先申请信号量 WaitForSingleObject(mutex,INFINITE);//再申请互斥量 /*进入临界区*/ printf("I am producting,please waiting.....\n"); BUFFER[in]=p_item; in=(in+1)%cur_size; front=(front+1)%max_buf_size; PrintBuf(BUFFER,cur_size); printf("I am ready for exiting.\n"); //退出临界区 ReleaseMutex(mutex); ReleaseSemaphore(full,1,0); } //线程结束后，将ThreadCompleted值加1 InterlockedIncrement(&ThreadCompleted); if(ThreadCompleted ==2) SetEvent(evtTerminate); return 0; } //消费者线程函数 unsigned long __stdcall c_Thread(void *theBuf) { while(true) { Sleep(3000); if(front==tail) { printf("The buffer is empty!\n"); sleep_time-=3000; } //P操作 WaitForSingleObject(full,INFINITE); WaitForSingleObject(mutex,INFINITE); printf("A consumer has enter the critiction .\n"); BUFFER[out]=c_item; out=(out+1)%cur_size; tail=(tail+1)%max_buf_size; PrintBuf(BUFFER,cur_size); printf("the consumer has exit the critiction.\n"); //V操作 ReleaseMutex(mutex); ReleaseSemaphore(empty,1,0); } //同生产者进程 InterlockedIncrement(&ThreadCompleted); if(ThreadCompleted ==2) SetEvent(evtTerminate); return 0; } //打印缓冲区 void PrintBuf(int buf[],int buf_size) { int i; printf("The state of the buffer:\n"); for(i=0;i<buf_size;i++) printf("%d,",buf[i]); printf("\n"); Sleep(1000); //此函数是为了线程相临两次访问临界区时有序的打印缓冲区内容， //并不是必须的，你可以不要，但模拟的近似度就大打折扣了。 }