win32下多线程同步方式之临界区，互斥量，事件对象，信号量

Posted 2022-06-09 shixin_0125

// win32_thread_syn.cpp : 定义控制台应用程序的入口点。
//

#include "stdafx.h"
#include "iostream"
#include "list"
#include "windows.h"
#include "process.h"

using namespace std;
/*
线程同步
1.临界区
2.信号量
3.事件对象
4.互斥量
*/

/************************************************************************/
/* 临界区    单进程内线程同步                                   */
/************************************************************************/
CRITICAL_SECTION g_cri;   //临界区
list<int> g_list2;
unsigned int __stdcall threadRead(LPVOID param)

    while(true)
    
        EnterCriticalSection(&g_cri);
        for (list<int>::iterator it = g_list2.begin(); it != g_list2.end();it++)
        
            cout << "元素为:"<<*it << endl;
        
        LeaveCriticalSection(&g_cri);
        Sleep(100);
    
    return 0;


unsigned int __stdcall threadWrite(LPVOID param)

    srand(GetTickCount());
    while (true)
    
        EnterCriticalSection(&g_cri);
        if (g_list2.size()>0)
        
            if (rand() % 100 > 50)
            
                g_list2.push_back(rand());
            
            else
            
                g_list2.erase(g_list2.begin());
            
        
        else
        
            g_list2.push_back(rand());
        
        LeaveCriticalSection(&g_cri);
        Sleep(100);
    
    return 0;


HANDLE g_mutex;  //互斥量

unsigned int times = 0;
/************************************************************************/
/*   互斥量                                                              */
/************************************************************************/
unsigned int __stdcall firstThread(LPVOID param)

    while (true)
    
        WaitForSingleObject(g_mutex, INFINITE);
        if (times <=20)
        
            cout << "线程1的第" << times++ << "次.." << endl;
        
        else
        
            break;
        
        ReleaseMutex(g_mutex);
    
    return 0;


unsigned int __stdcall secondThread(LPVOID param)

    while (true)
    
        WaitForSingleObject(g_mutex, INFINITE);
        if (times <= 20)
        
            Sleep(1);
            cout << "线程2的第" << times++ << "次.." << endl;
        
        else
        
            break;
        
        ReleaseMutex(g_mutex);
    
    return 0;



/************************************************************************/
/* 事件对象     可对进程外的线程同步   
    CreateEvent(NULL, false, false, NULL);
    setEvent(g_event);
*/
/************************************************************************/

HANDLE g_event;
unsigned int __stdcall firstThread2(LPVOID param)

    while (true)
    
        WaitForSingleObject(g_event, INFINITE);
        if (times <= 20)
        
            cout << "线程1的第" << times++ << "次.." << endl;
        
        else
        
            break;
        
        SetEvent(g_event);
        
    
    return 0;


unsigned int __stdcall secondThread2(LPVOID param)

    while (true)
    
        WaitForSingleObject(g_event, INFINITE);
        if (times <= 20)
        
            Sleep(1);
            cout << "线程2的第" << times++ << "次.." << endl;
        
        else
        
            break;
            
        SetEvent(g_event);
    
    return 0;


/************************************************************************/
/* 信号量   主要是可以指定个数
   允许多个线程同一时刻访问同一资源，我们可以指定允许个数
*/
/************************************************************************/
HANDLE g_semaphore;

unsigned int __stdcall firstThread3(LPVOID param)

    while (true)
    
        WaitForSingleObject(g_semaphore, INFINITE);
        if (times <= 20)
        
            cout << "线程1的第" << times++ << "次.." << endl;
        
        else
        
            break;
        
        ReleaseSemaphore(g_semaphore, 1, NULL);

    
    return 0;


unsigned int __stdcall secondThread3(LPVOID param)

    while (true)
    
        WaitForSingleObject(g_semaphore, INFINITE);
        if (times <= 20)
        
            Sleep(1);
            cout << "线程2的第" << times++ << "次.." << endl;
        
        else
        
            break;
        
        ReleaseSemaphore(g_semaphore, 1, NULL);
        
    
    return 0;


int _tmain(int argc, _TCHAR临界区互斥量事件信号量四种方式

 线程同步的方式和机制
 进程/线程同步的方式和机制，进程间通信
 进程之间的通信
 多线程编程之Windows同步方式
 RTOS基础之线程间同步