生產(chǎn)者與消費(fèi)者算法-展示頁(yè)
2025-05-25 06:54本頁(yè)面
【正文】 _NUM。 Thread_Info[j].n_request = 0。kMAX_THREAD_NUM。jMAX_THREAD_NUM。i++) Buffer_Critical[i] = 1。 //初始化緩沖區(qū)； for(int i=0。int main(void){ //聲明所需變量； DWORD wait_for_all。int FindProducePositon()。void Consume(void *p)。 //實(shí)際的緩沖區(qū)或者臨界區(qū)的數(shù)目；HANDLE h_Semaphore[MAX_THREAD_NUM]。 //一個(gè)互斥量；DWORD n_Thread = 0。 //線程信息數(shù)組；HANDLE empty_semaphore。 //緩沖區(qū)聲明，用于存放產(chǎn)品；HANDLE h_Thread[MAX_THREAD_NUM]。//全局變量的定義//臨界區(qū)對(duì)象的聲明,用于管理緩沖區(qū)的互斥訪問(wèn)；CRITICAL_SECTION PC_Critical[MAX_BUFFER_NUM]。 //線程請(qǐng)求隊(duì)列 int n_request。 //是P還是C double delay。includeincludeincludeincludestringinclude//定義一些常量；//本程序允許的最大臨界區(qū)數(shù)；define MAX_BUFFER_NUM 10//秒到微秒的乘法因子；define INTE_PER_SEC 1000//本程序允許的生產(chǎn)和消費(fèi)線程的總數(shù)；define MAX_THREAD_NUM 64//定義一個(gè)結(jié)構(gòu)，記錄在測(cè)試文件中指定的每一個(gè)線程的參數(shù)struct ThreadInfo{ int serial。 //線程序列號(hào) char entity。 //線程延遲 int thread_request[MAX_THREAD_NUM]。 //請(qǐng)求個(gè)數(shù)}。 int Buffer_Critical[MAX_BUFFER_NUM]。 //用于存儲(chǔ)每個(gè)線程句柄的數(shù)組；ThreadInfo Thread_Info[MAX_THREAD_NUM]。 //一個(gè)信號(hào)量；HANDLE h_mutex。 //實(shí)際的線程的數(shù)目；DWORD n_Buffer_or_Critical。 //生產(chǎn)者允許消費(fèi)者開始消費(fèi)的信號(hào)量；//生產(chǎn)消費(fèi)及輔助函數(shù)的聲明void Produce(void *p)。 bool IfInOtherRequest(int)。int FindBufferPosition(int)。 ifstream inFile。i MAX_BUFFER_NUM。 //初始化每個(gè)線程的請(qǐng)求隊(duì)列； for(int j=0。j++){ for(int k=0。k++) Thread_Info[j].
公司管理相關(guān)推薦
鄂ICP備17016276號(hào)-1