摄影网站开发背景,配送系统网站怎么做,买一个网页需要多少钱,毕业设计做网站起个名字一#xff0c;题目#xff1a; 生产者消费者线程演示 一个生产者线程将int类型的数入列#xff0c;一个消费者线程将int类型的数出列 二#xff0c;分析#xff1a; 这一个#xff0c;为操作系统上的一个经典例子#xff0c;以下是july给出的解答 … 一题目 生产者消费者线程演示 一个生产者线程将int类型的数入列一个消费者线程将int类型的数出列 二分析 这一个为操作系统上的一个经典例子以下是july给出的解答 三源码 #include windows.h #include stdio.h #include process.h #include iostream #include queue using namespace std; HANDLE ghSemaphore; //信号量 const int gMax 100; //生产(消费)总数 std::queueint q; //生产入队,消费出队 //生产者线程 unsigned int __stdcall producerThread(void* pParam) { int n 0; while(n gMax) { //生产 q.push(n); coutproducenendl; ReleaseSemaphore(ghSemaphore, 1,NULL); //增加信号量 Sleep(300);//生产间隔的时间,可以和消费间隔时间一起调节 } _endthread(); //生产结束 return 0; } //消费者线程 unsigned int __stdcall customerThread(void* pParam) { int n gMax; while(n--) { WaitForSingleObject(ghSemaphore, 10000); //消费 q.pop(); coutcustom q.front()endl; //小肥杨指出原答案这句和上句搞错了顺序? Sleep(500);//消费间隔的时间,可以和生产间隔时间一起调节 } //消费结束 CloseHandle(ghSemaphore); coutworking end.endl; _endthread(); return 0; } void threadWorking() { ghSemaphore CreateSemaphore(NULL, 0, gMax, NULL); //信号量来维护线程同步 coutworkingstart.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; } 转载于:https://www.cnblogs.com/tianshuai11/archive/2012/04/22/2477163.html
