伊甸园精品99久久久久久,午夜精品免费在线,亚洲男人的天堂在线

軟件課程設(shè)計2 生產(chǎn)者消費者問題

#include <windows.h>

#include <conio.h>

#include <fstream>

#include <cstdio>

#include <cmath>

#include <deque>

using namespace std;

#define FULL 9

#define EMPTY 0

int const maxn = 64;

deque<int>prime;

int nProduce=0;

int nConsumer=0;

HANDLE hMutex;

HANDLE sFull;

HANDLE sEmpty;

struct ThreadInfo

{

int id;//進程號

char type;//類型

int s;//start

int t;//end

};

void PrimePriority(char *file);

void ReadThread(void *p);

void FindThread(void *p);

bool check(int n);//檢查是否為素數(shù)

//main function

int main( int agrc, char* argv[] )

{

char ch;

prime.clear();

while (true)

{

// Cleare screen

system( "cls" );

// display prompt info

printf("*********************************************\n");

printf(" 1.Start test\n");

printf(" 2.Exit to Windows\n");

printf("*********************************************\n");

printf("Input your choice(1or2): ");

// if the number inputed is error, retry!

do{

ch = (char)_getch();

}while( ch != '1' && ch != '2');

system ( "cls" );

if ( ch == '1')

PrimePriority("ex4.dat");

else if ( ch == '2')

return 0;

printf("\nPress any key to finish this Program. \nThank you test this Proggram!\n");

_getch();

} //endvalue while

} //endvalue main

bool Cheak(int n)

{

for(int i=2;i<n;i++)if(n%i==0)return false;

return true;

}

void PrimePriority( char* file )

{

//定義

int nThread=0;

int tem;

HANDLE hThread[maxn];

DWORD threadID[maxn];

ThreadInfo threadInfo[maxn];

//初始化

nProduce=nConsumer=0;

sFull=CreateSemaphore(NULL,0,9,"full");

sEmpty=CreateSemaphore(NULL,9,9,"empty");

hMutex=CreateMutex(NULL,false,"mutex");

//文件讀入

ifstream inFile;

inFile.open(file); //open file

while ( inFile )

{

// read every reader/writer info

inFile>>threadInfo[nThread].id;

inFile>>threadInfo[nThread].type;

inFile>>threadInfo[nThread].s;

inFile>>threadInfo[nThread++].t;

inFile.get();

}

//收集信息

for(int i=0;i<nThread;i++)

{

char ch=threadInfo[i].type;

if(ch=='D'||ch=='d')nConsumer++;

if(ch=='W'||ch=='w')nProduce++;

}

//創(chuàng)建線程

for(int i=0;i<nThread;i++)

{

char ch=threadInfo[i].type;

if(ch=='D'||ch=='d')hThread[i] = CreateThread(

NULL,0,(LPTHREAD_START_ROUTINE)ReadThread,&threadInfo[i],0,&threadID[i]);

if(ch=='W'||ch=='w')hThread[i] = CreateThread(

NULL,0,(LPTHREAD_START_ROUTINE)FindThread,&threadInfo[i],0,&threadID[i]);

}

WaitForMultipleObjects(nThread,hThread,true,INFINITE);

printf("所有線程結(jié)束\n");

CloseHandle(hMutex);

CloseHandle(sEmpty);

CloseHandle(sFull);

}// endvalue readerPriority

void ReadThread(void *p)

{

//定義子Handle

HANDLE h_Mutex;

HANDLE s_Full;

HANDLE s_Empty;

//初始化

s_Full = OpenSemaphore(SEMAPHORE_ALL_ACCESS,FALSE,"full");

s_Empty = OpenSemaphore(SEMAPHORE_ALL_ACCESS,FALSE,"empty");

h_Mutex = OpenMutex(MUTEX_ALL_ACCESS,FALSE,"mutex");

int id,n;

id = ((ThreadInfo*)p)->id;

n = ((ThreadInfo*)p)->s;

for(int i=0;i<n;i++)

{

//block one

WaitForSingleObject(h_Mutex,INFINITE);

if(nProduce==0 && prime.empty()){

printf("生產(chǎn)者已結(jié)束，數(shù)組中為空，消費者線程被迫結(jié)束\n");

ReleaseMutex(h_Mutex);//不要忘了釋放

break;

}

ReleaseMutex(h_Mutex);

//block two

WaitForSingleObject(s_Full,INFINITE);

WaitForSingleObject(h_Mutex,INFINITE);

printf("消費者線程 %d[%d] 取出了第 %d 個元素: %d \n",id,n,i+1,prime.front());

prime.pop_front();

printf("此時隊列中的數(shù)字為:");

for(deque<int>::iterator it=prime.begin();it!=prime.end();it++){

printf("%d ",*it);

}

printf("\n\n\n");

ReleaseMutex(h_Mutex);

ReleaseSemaphore(s_Empty,1,NULL);

}

printf("消費者 %d 結(jié)束\n\n\n",id);

nConsumer--;

}

void FindThread(void *p)

{

//定義子Handle

HANDLE h_Mutex;

HANDLE s_Full;

HANDLE s_Empty;

//初始化

s_Full = OpenSemaphore(SEMAPHORE_ALL_ACCESS,FALSE,"full");

s_Empty = OpenSemaphore(SEMAPHORE_ALL_ACCESS,FALSE,"empty");

h_Mutex = OpenMutex(MUTEX_ALL_ACCESS,FALSE,"mutex");

int id,s,t;

id = ((ThreadInfo*)p) -> id;

s = ((ThreadInfo*)p) -> s;

t= ((ThreadInfo*)p) -> t;

int primeNum=0;

for(int i=s;i<=t;i++)

if(Cheak(i))primeNum++;

int produceNum=0;

for(int i=s;i<=t;i++)

{

if(Cheak(i))

{

WaitForSingleObject(h_Mutex,INFINITE);

if(nConsumer==EMPTY && prime.size()==FULL)

{

printf("消費者已經(jīng)結(jié)束,存儲空間已滿\n");

ReleaseMutex(h_Mutex);

break;

}

ReleaseMutex(h_Mutex);

WaitForSingleObject(s_Empty,INFINITE);

WaitForSingleObject(h_Mutex,INFINITE);

printf("生產(chǎn)者 %d[%d] 在隊尾插入了第 %d 個元素 %d \n",id,primeNum,++produceNum,i);

prime.push_back(i);

printf("此時隊列中的數(shù)字為:");

for(deque<int>::iterator it=prime.begin();it!=prime.end();it++){

printf("%d ",*it);

}

printf("\n\n\n");

ReleaseMutex(h_Mutex);

ReleaseSemaphore(s_Full,1,NULL);

}

printf("生產(chǎn)者 %d 結(jié)束.\n\n\n",id);

CloseHandle(h_Mutex);

CloseHandle(s_Full);

CloseHandle(s_Empty);

nProduce--;

}

posted on 2011-01-05 02:27 abilitytao 閱讀(852) 評論(0) 編輯收藏引用

只有注冊用戶登錄后才能發(fā)表評論。
【推薦】100%開源！大型工業(yè)跨平臺軟件C++源碼提供，建模，組態(tài)！



網(wǎng)站導(dǎo)航: 博客園 IT新聞 BlogJava 博問 Chat2DB 管理

The Fourth Dimension Space

導(dǎo)航

統(tǒng)計

常用鏈接

留言簿(16)

隨筆檔案

文章檔案

Blogs in Computer Vision and Algorithm

友情鏈接

搜索

最新評論

閱讀排行榜

評論排行榜

軟件課程設(shè)計2 生產(chǎn)者消費者問題