C++线程同步 -- windows
简介:
在一般情况下,创建一个线程是不能提高程序的执行效率的,所以要创建多个线程。但是多个线程同时运行的时候可能调用线程函数,在多个线程同时对同一个内存地址进行写入,
由于CPU时间调度上的问题,写入数据会被多次的覆盖,所以就要使线程同步。
同步就是协同步调,按预定的先后次序进行运行。如:你说完,我再说。
#include <Windows.h>
#include <iostream> using namespace std; int number = ; unsigned long __stdcall ThreadProc1(void* lp)
{
while(number < )
{
cout << "thread 1: " << number << endl;
++number;
_sleep();
}
return ;
} unsigned long __stdcall ThreadProc2(void* lp)
{
while(number < )
{
cout << "thread 1: " << number << endl;
++number;
_sleep();
}
return ;
} int main()
{
CreateThread(NULL,,ThreadProc1,NULL,,NULL);
CreateThread(NULL,,ThreadProc2,NULL,,NULL); Sleep(*); system("pause");
return ;
}
(3)临界区(Critical section)
信号量是维护0到指定最大值之间的同步对象。信号量状态在其计数大于0时是有信号的,而其计数是0时是无信号的。信号量对象在控制上可以支持有限数量共享资源的访问。
信号量的特点和用途可用下列几句话定义:
(1)如果当前资源的数量大于0,则信号量有效;
(2)如果当前资源数量是0,则信号量无效;
(3)系统决不允许当前资源的数量为负值;
(4)当前资源数量决不能大于最大资源数量。
创建信号量
HANDLE CreateSemaphore (
PSECURITY_ATTRIBUTE psa, //信号量的安全属性
LONG lInitialCount, //开始时可供使用的资源数
LONG lMaximumCount, //最大资源数
PCTSTR pszName); //信号量的名称
释放信号量
通过调用ReleaseSemaphore函数,线程就能够对信标的当前资源数量进行递增,该函数原型为:
BOOL WINAPI ReleaseSemaphore(
HANDLE hSemaphore, //要增加的信号量句柄
LONG lReleaseCount, //信号量的当前资源数增加lReleaseCount
LPLONG lpPreviousCount //增加前的数值返回
);
打开信号量
和其他核心对象一样,信号量也可以通过名字跨进程访问,打开信号量的API为:
HANDLE OpenSemaphore (
DWORD fdwAccess, //access
BOOL bInherithandle, //如果允许子进程继承句柄,则设为TRUE
PCTSTR pszName //指定要打开的对象的名字
);
实例
#include<windows.h>
#include<iostream>
using namespace std; int number = ; //定义全局变量
HANDLE hSemaphore; //定义信号量句柄 unsigned long __stdcall ThreadProc1(void* lp)
{
long count;
while (number < )
{
WaitForSingleObject(hSemaphore, INFINITE); //等待信号量为有信号状态
cout << "thread 1 :"<<number << endl;
++number;
_sleep();
ReleaseSemaphore(hSemaphore, , &count);
} return ;
} unsigned long __stdcall ThreadProc2(void* lp)
{
long count;
while (number < )
{
WaitForSingleObject(hSemaphore, INFINITE); //等待信号量为有信号状态
cout << "thread 2 :"<<number << endl;
++number;
_sleep();
ReleaseSemaphore(hSemaphore, , &count);
} return ;
} int main()
{
hSemaphore = CreateSemaphore(NULL, , , "sema"); CreateThread(NULL, , ThreadProc1, NULL, , NULL);
CreateThread(NULL, , ThreadProc2, NULL, , NULL); Sleep(*); system("pause");
return ;
}
-------------------------------------互斥量----------------------------------------------------
采用互斥对象机制。 只有拥有互斥对象的线程才有访问公共资源的权限,因为互斥对象只有一个,所以能保证公共资源不会同时被多个线程访问。互斥不仅能实现同一应用程序的公共资源安全共享,还能实现不同应用程序的公共资源安全共享。
#include<windows.h>
#include<iostream>
using namespace std; int number = ; //定义全局变量
HANDLE hMutex; //定义互斥对象句柄 unsigned long __stdcall ThreadProc1(void* lp)
{
while (number < )
{
WaitForSingleObject(hMutex, INFINITE);
cout << "thread 1 :"<<number << endl;
++number;
_sleep();
ReleaseMutex(hMutex);
} return ;
} unsigned long __stdcall ThreadProc2(void* lp)
{
while (number < )
{
WaitForSingleObject(hMutex, INFINITE);
cout << "thread 2 :"<<number << endl;
++number;
_sleep();
ReleaseMutex(hMutex);
} return ;
} int main()
{
hMutex = CreateMutex(NULL, false, "mutex"); //创建互斥对象 CreateThread(NULL, , ThreadProc1, NULL, , NULL);
CreateThread(NULL, , ThreadProc2, NULL, , NULL); Sleep(*); system("pause");
return ;
}
-------------------------------------临界区----------------------------------------------------
临界区(Critical Section)是一段独占对某些共享资源访问的代码,在任意时刻只允许一个线程对共享资源进行访问。如果有多个线程试图同时访问临界区,那么在有一个线程进入后其他所有试图访问此临界区的线程将被挂起,并一直持续到进入临界区的线程离开。临界区在被释放后,其他线程可以继续抢占,并以此达到用原子方式操作共享资源的目的。
临界区在使用时以CRITICAL_SECTION结构对象保护共享资源,并分别用EnterCriticalSection()和LeaveCriticalSection()函数去标识和释放一个临界区。所用到的CRITICAL_SECTION结构对象必须经过InitializeCriticalSection()的初始化后才能使用,而且必须确保所有线程中的任何试图访问此共享资源的代码都处在此临界区的保护之下。否则临界区将不会起到应有的作用,共享资源依然有被破坏的可能。
#include<windows.h>
#include<iostream>
using namespace std; int number = ; //定义全局变量
CRITICAL_SECTION Critical; //定义临界区句柄 unsigned long __stdcall ThreadProc1(void* lp)
{
while (number < )
{
EnterCriticalSection(&Critical);
cout << "thread 1 :"<<number << endl;
++number;
_sleep();
LeaveCriticalSection(&Critical);
} return ;
} unsigned long __stdcall ThreadProc2(void* lp)
{
while (number < )
{
EnterCriticalSection(&Critical);
cout << "thread 2 :"<<number << endl;
++number;
_sleep();
LeaveCriticalSection(&Critical);
} return ;
} int main()
{
InitializeCriticalSection(&Critical); //初始化临界区对象 CreateThread(NULL, , ThreadProc1, NULL, , NULL);
CreateThread(NULL, , ThreadProc2, NULL, , NULL); Sleep(*); system("pause");
return ;
}
#include <Windows.h>
#include <iostream> using namespace std; int number = ; //定义全局变量
HANDLE hEvent; //定义事件句柄 unsigned long __stdcall ThreadProc1(void* lp)
{
while (number < )
{
WaitForSingleObject(hEvent,INFINITE);
cout << "Thread 1 :" << number << endl;
++number;
_sleep();
SetEvent(hEvent);
}
return ;
} unsigned long __stdcall ThreadProc2(void* lp)
{
while (number < )
{
WaitForSingleObject(hEvent,INFINITE);
cout << "Thread 2 :" << number << endl;
++number;
_sleep();
SetEvent(hEvent);
}
return ;
} int main()
{
CreateThread(NULL, , ThreadProc1, NULL, , NULL);
CreateThread(NULL, , ThreadProc2, NULL, , NULL);
hEvent = CreateEvent(NULL, FALSE, TRUE, L"event"); // Sleep(*); system("pause");
return ;
}
最新文章
- 使用Microsoft Web Application Stress Tool对web进行压力测试
- js/json 数组的操作
- private、 protected、 public、 internal 修饰符
- GTX 770 (GK 104)
- shell MAC 地址 校验
- H264的句法和语法总结(一)分层结构
- <;转>;Linux环境进程间通信(二): 信号(下)
- asp.net 常用的几种调用存储过程的方法
- (转)一个form表单实现提交多个action
- CSS常用操作-导航栏
- 10个优秀个android项目,精选|快速开发
- 第一篇、vlc-android之开篇介绍
- js 阻止事件执行
- tomcat之过滤器
- 转:Redis 使用经验总结
- 微信小程序 验证码倒计时组件
- 8-51单片机ESP8266学习-AT指令(单片机采集温湿度数据通过8266发送给C#TCP客户端显示)
- BZOJ1652 [Usaco2006 Feb]Treats for the Cows
- 爬虫实战--基于requests和beautifulsoup的妹子网图片爬取(福利哦!)
- Madgwick算法详细解读
热门文章
- nodejs之流数据读取与写入
- 阶段3 2.Spring_07.银行转账案例_5 编写业务层和持久层事务控制代码并配置spring的ioc
- 1 Configuring SAP ERP Sales and Distribution -introduction to SAP
- MyBatis框架原理4:插件
- CentOS7中SSH免密登陆设置
- 【PyTorch】PyTorch使用LMDB数据库加速文件读取
- python 并发编程 多线程 event
- HDU-4332-Constructing Chimney
- C语言 --- 函数指针(初级)
- jmeter---linux安装运行