标签：set 线程同步 object 修改 inf ret 演示 stdcall thread
简介：
在一般情况下，创建一个线程是不能提高程序的执行效率的，所以要创建多个线程。但是多个线程同时运行的时候可能调用线程函数，在多个线程同时对同一个内存地址进行写入，
由于CPU时间调度上的问题，写入数据会被多次的覆盖，所以就要使线程同步。
同步就是协同步调，按预定的先后次序进行运行。如：你说完，我再说。
1 #include <Windows.h> 2 #include <iostream> 3 4 using namespace std; 5 6 int number = 1; 7 8 unsigned long __stdcall ThreadProc1(void* lp) 9 { 10 while(number < 100) 11 { 12 cout << "thread 1: " << number << endl; 13 ++number; 14 _sleep(100); 15 } 16 return 0; 17 } 18 19 unsigned long __stdcall ThreadProc2(void* lp) 20 { 21 while(number < 100) 22 { 23 cout << "thread 1: " << number << endl; 24 ++number; 25 _sleep(100); 26 } 27 return 0; 28 } 29 30 int main() 31 { 32 CreateThread(NULL,0,ThreadProc1,NULL,0,NULL); 33 CreateThread(NULL,0,ThreadProc2,NULL,0,NULL); 34 35 Sleep(10*1000); 36 37 system("pause"); 38 return 0; 39 }
信号量是维护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 = 1; //定义全局变量 HANDLE hSemaphore; //定义信号量句柄 unsigned long __stdcall ThreadProc1(void* lp) { long count; while (number < 100) { WaitForSingleObject(hSemaphore, INFINITE); //等待信号量为有信号状态 cout << "thread 1 :"<<number << endl; ++number; _sleep(100); ReleaseSemaphore(hSemaphore, 1, &count); } return 0; } unsigned long __stdcall ThreadProc2(void* lp) { long count; while (number < 100) { WaitForSingleObject(hSemaphore, INFINITE); //等待信号量为有信号状态 cout << "thread 2 :"<<number << endl; ++number; _sleep(100); ReleaseSemaphore(hSemaphore, 1, &count); } return 0; } int main() { hSemaphore = CreateSemaphore(NULL, 1, 100, "sema"); CreateThread(NULL, 0, ThreadProc1, NULL, 0, NULL); CreateThread(NULL, 0, ThreadProc2, NULL, 0, NULL); Sleep(10*1000); system("pause"); return 0; }
-------------------------------------互斥量----------------------------------------------------
采用互斥对象机制。 只有拥有互斥对象的线程才有访问公共资源的权限，因为互斥对象只有一个，所以能保证公共资源不会同时被多个线程访问。互斥不仅能实现同一应用程序的公共资源安全共享，还能实现不同应用程序的公共资源安全共享。
#include<windows.h> #include<iostream> using namespace std; int number = 1; //定义全局变量 HANDLE hMutex; //定义互斥对象句柄 unsigned long __stdcall ThreadProc1(void* lp) { while (number < 100) { WaitForSingleObject(hMutex, INFINITE); cout << "thread 1 :"<<number << endl; ++number; _sleep(100); ReleaseMutex(hMutex); } return 0; } unsigned long __stdcall ThreadProc2(void* lp) { while (number < 100) { WaitForSingleObject(hMutex, INFINITE); cout << "thread 2 :"<<number << endl; ++number; _sleep(100); ReleaseMutex(hMutex); } return 0; } int main() { hMutex = CreateMutex(NULL, false, "mutex"); //创建互斥对象 CreateThread(NULL, 0, ThreadProc1, NULL, 0, NULL); CreateThread(NULL, 0, ThreadProc2, NULL, 0, NULL); Sleep(10*1000); system("pause"); return 0; }
-------------------------------------临界区----------------------------------------------------
临界区（Critical Section）是一段独占对某些共享资源访问的代码，在任意时刻只允许一个线程对共享资源进行访问。如果有多个线程试图同时访问临界区，那么在有一个线程进入后其他所有试图访问此临界区的线程将被挂起，并一直持续到进入临界区的线程离开。临界区在被释放后，其他线程可以继续抢占，并以此达到用原子方式操作共享资源的目的。
临界区在使用时以CRITICAL_SECTION结构对象保护共享资源，并分别用EnterCriticalSection（）和LeaveCriticalSection（）函数去标识和释放一个临界区。所用到的CRITICAL_SECTION结构对象必须经过InitializeCriticalSection（）的初始化后才能使用，而且必须确保所有线程中的任何试图访问此共享资源的代码都处在此临界区的保护之下。否则临界区将不会起到应有的作用，共享资源依然有被破坏的可能。
#include<windows.h> #include<iostream> using namespace std; int number = 1; //定义全局变量 CRITICAL_SECTION Critical; //定义临界区句柄 unsigned long __stdcall ThreadProc1(void* lp) { while (number < 100) { EnterCriticalSection(&Critical); cout << "thread 1 :"<<number << endl; ++number; _sleep(100); LeaveCriticalSection(&Critical); } return 0; } unsigned long __stdcall ThreadProc2(void* lp) { while (number < 100) { EnterCriticalSection(&Critical); cout << "thread 2 :"<<number << endl; ++number; _sleep(100); LeaveCriticalSection(&Critical); } return 0; } int main() { InitializeCriticalSection(&Critical); //初始化临界区对象 CreateThread(NULL, 0, ThreadProc1, NULL, 0, NULL); CreateThread(NULL, 0, ThreadProc2, NULL, 0, NULL); Sleep(10*1000); system("pause"); return 0; }
#include <Windows.h> #include <iostream> using namespace std; int number = 1; //定义全局变量 HANDLE hEvent; //定义事件句柄 unsigned long __stdcall ThreadProc1(void* lp) { while (number < 100) { WaitForSingleObject(hEvent,INFINITE); cout << "Thread 1 :" << number << endl; ++number; _sleep(100); SetEvent(hEvent); } return 0; } unsigned long __stdcall ThreadProc2(void* lp) { while (number < 100) { WaitForSingleObject(hEvent,INFINITE); cout << "Thread 2 :" << number << endl; ++number; _sleep(100); SetEvent(hEvent); } return 0; } int main() { CreateThread(NULL, 0, ThreadProc1, NULL, 0, NULL); CreateThread(NULL, 0, ThreadProc2, NULL, 0, NULL); hEvent = CreateEvent(NULL, FALSE, TRUE, L"event"); // Sleep(10*1000); system("pause"); return 0; }
标签：set 线程同步 object 修改 inf ret 演示 stdcall thread
原文地址：https://www.cnblogs.com/wzqstudy/p/12093158.html
