博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
C++之线程信号量机制
阅读量:2194 次
发布时间:2019-05-02

本文共 1372 字,大约阅读时间需要 4 分钟。

http://blog.csdn.net/riyuedangkong1/article/details/52462057

  1. #include<iostream>  
  2. #include<Windows.h>  
  3. using namespace std;  
  4. int tickets=100;         //火车票总数  
  5. HANDLE hSemaphore;  
  6. DWORD WINAPI Thread1Proc(LPVOID lpParameter);//进程函数  
  7. DWORD WINAPI Thread2Proc(LPVOID lpParameter);//进程函数  
  8. void main()  
  9. {  
  10.     HANDLE hThread1;  
  11.     HANDLE hThread2;  
  12.     hThread1=CreateThread(NULL,0,Thread1Proc,NULL,0,NULL);   //创建线程  
  13.     hThread2=CreateThread(NULL,0,Thread2Proc,NULL,0,NULL);  
  14.     hSemaphore=CreateSemaphore(NULL,1,1,NULL);      //创建信号量,初始为1,最多为1  
  15.     CloseHandle(hThread1);       //释放句柄  
  16.     CloseHandle(hThread2);  
  17.     CloseHandle(hSemaphore);  
  18.     while(TRUE)  
  19.     {  
  20.         WaitForSingleObject(hSemaphore,INFINITE);  
  21.         if(tickets>0)  
  22.         {  
  23.             cout<<"主线程卖出第"<<tickets--<<"张票"<<endl;  
  24.             Sleep(50);  
  25.             ReleaseSemaphore(hSemaphore,1,NULL);  
  26.         }  
  27.         else  
  28.         {  
  29.             ReleaseSemaphore(hSemaphore,1,NULL);      //释放信号量资源  
  30.             break;  
  31.         }  
  32.     }  
  33.     ExitThread(0);  
  34. }  
  35. DWORD WINAPI Thread1Proc(LPVOID lpParameter)  
  36. {  
  37.     while(TRUE)  
  38.     {  
  39.         WaitForSingleObject(hSemaphore,INFINITE);//申请信号量  
  40.         if(tickets>0)  
  41.         {  
  42.            cout<<"线程一卖掉第"<<tickets--<<"张票"<<endl;  
  43.            Sleep(50);  
  44.            ReleaseSemaphore(hSemaphore,1,NULL);  
  45.         }  
  46.         else  
  47.         {  
  48.             ReleaseSemaphore(hSemaphore,1,NULL);  
  49.             break;  
  50.         }  
  51.     }  
  52.     return 0;  
  53. }  
  54. DWORD WINAPI Thread2Proc(LPVOID lpParameter)  
  55. {  
  56.     while(TRUE)  
  57.     {  
  58.         WaitForSingleObject(hSemaphore,INFINITE);  
  59.         if(tickets>0)  
  60.         {  
  61.             cout<<"线程二卖出第"<<tickets--<<"张票"<<endl;  
  62.             Sleep(50);  
  63.             ReleaseSemaphore(hSemaphore,1,NULL);  
  64.         }  
  65.         else  
  66.         {  
  67.             ReleaseSemaphore(hSemaphore,1,NULL);  
  68.             break;  
  69.         }  
  70.     }  
  71.     return 0;  

你可能感兴趣的文章
探索Redis设计与实现4:Redis内部数据结构详解——ziplist
查看>>
探索Redis设计与实现6:Redis内部数据结构详解——skiplist
查看>>
探索Redis设计与实现5:Redis内部数据结构详解——quicklist
查看>>
探索Redis设计与实现8:连接底层与表面的数据结构robj
查看>>
探索Redis设计与实现7:Redis内部数据结构详解——intset
查看>>
探索Redis设计与实现9:数据库redisDb与键过期删除策略
查看>>
探索Redis设计与实现10:Redis的事件驱动模型与命令执行过程
查看>>
分布式系统理论基础1: 一致性、2PC和3PC
查看>>
分布式系统理论基础2 :CAP
查看>>
分布式系统理论基础3: 时间、时钟和事件顺序
查看>>
分布式系统理论基础4:Paxos
查看>>
分布式系统理论基础5:选举、多数派和租约
查看>>
分布式系统理论基础6:Raft、Zab
查看>>
分布式系统理论进阶7:Paxos变种和优化
查看>>
分布式系统理论基础8:zookeeper分布式协调服务
查看>>
搞懂分布式技术1:分布式系统的一些基本概念
查看>>
搞懂分布式技术2:分布式一致性协议与Paxos,Raft算法
查看>>
搞懂分布式技术3:初探分布式协调服务zookeeper
查看>>
搞懂分布式技术4:ZAB协议概述与选主流程详解
查看>>
搞懂分布式技术5:Zookeeper的配置与集群管理实战
查看>>