一，題目：

? ? ? ?生產(chǎn)者消費者線程演示??
? ? ? ? ? ? ? ? ? 一個生產(chǎn)者線程將int類型的數(shù)入列，一個消費者線程將int類型的數(shù)出列?

二，分析：

????????

? ? ? ? 這一個，為操作系統(tǒng)上的一個經(jīng)典例子，以下是july給出的解答 ? ?

三，源碼：

#include <windows.h> #include <stdio.h> #include <process.h> #include <iostream> #include <queue> using namespace std; HANDLE ghSemaphore; //信號量 const int gMax = 100; //生產(chǎn)(消費)總數(shù) std::queue<int> q; //生產(chǎn)入隊,消費出隊 //生產(chǎn)者線程 unsigned int __stdcall producerThread(void* pParam) { int n = 0; while(++n <= gMax) { //生產(chǎn) q.push(n); cout<<"produce"<<n<<endl; ReleaseSemaphore(ghSemaphore, 1,NULL); //增加信號量 Sleep(300);//生產(chǎn)間隔的時間,可以和消費間隔時間一起調(diào)節(jié) } _endthread(); //生產(chǎn)結(jié)束 return 0; } //消費者線程 unsigned int __stdcall customerThread(void* pParam) { int n = gMax; while(n--) { WaitForSingleObject(ghSemaphore, 10000); //消費 q.pop(); cout<<"custom "<<q.front()<<endl; //小肥楊指出，原答案這句和上句搞錯了順序? Sleep(500);//消費間隔的時間,可以和生產(chǎn)間隔時間一起調(diào)節(jié) } //消費結(jié)束 CloseHandle(ghSemaphore); cout<<"working end."<<endl; _endthread(); return 0; } void threadWorking() { ghSemaphore = CreateSemaphore(NULL, 0, gMax, NULL); //信號量來維護線程同步 cout<<"workingstart."<<endl; unsigned threadID; HANDLE handles[2]; handles[0] = (HANDLE)_beginthreadex( NULL, 0, producerThread, NULL, 0, &threadID); handles[1] = (HANDLE)_beginthreadex( NULL, 0, customerThread, NULL, 0, &threadID); WaitForMultipleObjects(2, handles, TRUE, INFINITE); } int main() { threadWorking(); getchar(); return 0; }

?

轉(zhuǎn)載于:https://www.cnblogs.com/tianshuai11/archive/2012/04/22/2477163.html

總結(jié)

以上是生活随笔為你收集整理的【100题】第三十四 实现一个队列的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。