讀者寫者問題c語言

Ⅰ 用c語言編程實現用信號量實現讀者--寫者問題(要源代碼)

汗 竟然是校友...
by monkeyking

Ⅱ 用c語言或c++編寫編程實現生產者消費者或讀寫者的同步問題

實現一個隊列CQueue
CQueue提供兩個公有成員函數
addTail()：往隊列尾部增加一個元素
removeHead()：讀出並移除隊列的第一個元素
生產者：兩個線程通過調用CQueue::addTail()往隊列中增加元素
消費者：一個線程通過調用CQueue::removeHead()從隊列中讀取元素
#include <iostream>
#include <list>
#include <windows.h>
#include <process.h>
using namespace std;

#define P(sem) WaitForSingleObject(sem,INFINITE)
#define V(sem) ReleaseSemaphore(sem,1,NULL)

class CQueue
{
public:
void addTail();//往隊列尾部增加一個元素
void removeHead();//讀出並移除隊列的第一個元素
private:
list<int> L;
};

CQueue buffer;//全局的緩沖區
const int buf_size = 10;//緩沖區大小

static int GOODS_ID = 0;//商品序號

const int procers = 3;//生產者數量
const int consumers = 8;//消費者數量

void ProcerThread(void* param);
void ConsumerThread(void* param);

HANDLE empty,occupy,op_mutex;

int main()
{
int i;
int p_id[procers],c_id[consumers];
occupy = CreateSemaphore(NULL,0,buf_size,NULL);//佔用位置
empty = CreateSemaphore(NULL,buf_size,buf_size,NULL);//空餘位置
op_mutex = CreateSemaphore(NULL,1,1,NULL);//操作互斥量

for(i=0;i<procers;++i)
{
p_id[i] = i+1;
_beginthread(ProcerThread,0,p_id+i);
}
for(i=0;i<consumers;++i)
{
c_id[i] = i+1;
_beginthread(ConsumerThread,0,c_id+i);
}
while(getchar()=='\n') break;
return 0;
}

void CQueue::addTail()
{
L.insert(L.end(),++GOODS_ID);
}

void CQueue::removeHead()
{
cout<<*L.begin()<<endl;
L.erase(L.begin());
}

void ProcerThread(void* param)
{
int id = *(int*)param;
while(1)
{
P(empty);
P(op_mutex);
Sleep(100);
buffer.addTail();
printf("Procer_%d proced %d\n",id,GOODS_ID);
V(op_mutex);
V(occupy);
}
}

void ConsumerThread(void* param)
{
int id = *(int*)param;
while(1)
{
P(occupy);
P(op_mutex);
Sleep(100);
printf("Consumer_%d consumed ",id);
buffer.removeHead();
V(op_mutex);
V(empty);
}
}