#include <windows.h>
#include <iostream.h>
struct semaphore //定义信号量
{
int value;
int num; //自定义队列
HANDLE handle[10];
};
struct semaphore empty,apple,orange,plate;
//empty:同步；apply：同步；orange：同步；plate：互斥
void wait(semaphore *S)
{
S->value=S->value-1;
if(S->value<0)
{ //阻塞线程并将其放置队列的尾部
HANDLE tempHandle;
DuplicateHandle(GetCurrentProcess(),GetCurrentThread(),
GetCurrentProcess(),&tempHandle,
0,FALSE,DUPLICATE_SAME_ACCESS);
S->handle[S->num]=tempHandle;
S->num++;
SuspendThread(tempHandle);
}
}
void signal(semaphore *S)
{
S->value=S->value+1;
if(S->value<=0)
{ //唤醒队列的第一个线程并将队列后面的对象前移
HANDLE tempHandle;
tempHandle=S->handle[0];
for(int i=1;i<S->num;i++)
S->handle[i-1]=S->handle[i];
S->num--;
ResumeThread(tempHandle);
}
}
DWORD WINAPI addapple(LPVOID lpParameter) //爸爸放苹果线程
{
while(true)
{
wait(&empty);
wait(&plate);
Sleep(5);
cout<<"爸爸放了一个苹果\n"<<endl;
signal(&plate);
signal(&apple);
}
}
DWORD WINAPI addorange(LPVOID lpParameter) //妈妈放桔子线程
{
while(true)
{
wait(&empty);
wait(&plate);
Sleep(5);
cout<<"妈妈放了一个桔子\n"<<endl;
signal(&plate);
signal(&orange);
}
}
DWORD WINAPI eatapple(LPVOID lpParameter) //女儿吃苹果线程
{
while(true)
{
wait(&apple);
Sleep(5);
cout<<"女儿吃了一个苹果\n"<<endl;
signal(&empty);
}
}
DWORD WINAPI eatorange(LPVOID lpParameter) //儿子吃桔子线程
{
while(true)
{
wait(&orange);
Sleep(5);
cout<<"儿子吃了一个桔子\n"<<endl;
signal(&empty);
}
}
void main() //主线程
{
empty.value=1;
empty.num=0;
apple.value=0;
apple.num=0;
orange.value=0;
orange.num=0;
plate.value=1;
plate.num=0;
HANDLE hThread1;
HANDLE hThread2;
HANDLE hThread3;
HANDLE hThread4;
//创建四个子线程
hThread1=CreateThread(NULL,0,addapple,NULL,0,NULL);
hThread2=CreateThread(NULL,0,addorange,NULL,0,NULL);
hThread3=CreateThread(NULL,0,eatapple,NULL,0,NULL);
hThread4=CreateThread(NULL,0,eatorange,NULL,0,NULL);
Sleep(150);
CloseHandle(hThread1);
CloseHandle(hThread2);
CloseHandle(hThread3);
CloseHandle(hThread4);
}
