线程同步的四种方式

2023-05-16

一,什么是线程同步和互斥

同步就是协同步调,按预定的先后次序进行运行。如:你说完,我再说。这里的同步千万不要理解成那个同时进行,应是指协同、协助、互相配合。线程同步是指多线程通过特定的设置(如互斥量,事件对象,临界区)来控制线程之间的执行顺序(即所谓的同步)也可以说是在线程之间通过同步建立起执行顺序的关系,如果没有同步,那线程之间是各自运行各自的!

线程互斥是指对于共享的进程系统资源,在各单个线程访问时的排它性。当有若干个线程都要使用某一共享资源时,任何时刻最多只允许一个线程去使用,其它要使用该资源的线程必须等待,直到占用资源者释放该资源。线程互斥可以看成是一种特殊的线程同步(下文统称为同步)。


文末收录了一篇关于并发 并行 同步 异步 多线程的区别(这是原文地址,尊重原创)

二,线程同步的方式和机制

临界区(Critical Section)、互斥对象(Mutex):主要用于互斥控制;都具有拥有权的控制方法,只有拥有该对象的线程才能执行任务,所以拥有,执行完任务后一定要释放该对象。

信号量(Semaphore)、事件对象(Event):事件对象是以通知的方式进行控制,主要用于同步控制!

1、临界区:通过对多线程的串行化来访问公共资源或一段代码,速度快,适合控制数据访问。在任意时刻只允许一个线程对共享资源进行访问,如果有多个线程试图访问公共资源,那么在有一个线程进入后,其他试图访问公共资源的线程将被挂起,并一直等到进入临界区的线程离开,临界区在被释放后,其他线程才可以抢占。它并不是核心对象,不是属于操作系统维护的,而是属于进程维护的。

总结下关键段:
1)关键段共初始化化、销毁、进入和离开关键区域四个函数。
2)关键段可以解决线程的互斥问题,但因为具有“线程所有权”,所以无法解决同步问题。
3)推荐关键段与旋转锁配合使用。

2、互斥对象:互斥对象和临界区很像,采用互斥对象机制,只有拥有互斥对象的线程才有访问公共资源的权限。因为互斥对象只有一个,所以能保证公共资源不会同时被多个线程同时访问。当前拥有互斥对象的线程处理完任务后必须将线程交出,以便其他线程访问该资源。

总结下互斥量Mutex:
1)互斥量是内核对象,它与关键段都有“线程所有权”所以不能用于线程的同步。
2)互斥量能够用于多个进程之间线程互斥问题,并且能完美的解决某进程意外终止所造成的“遗弃”问题。


3、信号量:信号量也是内核对象。它允许多个线程在同一时刻访问同一资源,但是需要限制在同一时刻访问此资源的最大线程数目

在用CreateSemaphore()创建信号量时即要同时指出允许的最大资源计数和当前可用资源计数。一般是将当前可用资源计数设置为最 大资源计数,每增加一个线程对共享资源的访问,当前可用资源计数就会减1 ,只要当前可用资源计数是大于0 的,就可以发出信号量信号。但是当前可用计数减小 到0 时则说明当前占用资源的线程数已经达到了所允许的最大数目,不能在允许其他线程的进入,此时的信号量信号将无法发出。线程在处理完共享资源后,应在离 开的同时通过ReleaseSemaphore ()函数将当前可用资源计数加1 。在任何时候当前可用资源计数决不可能大于最大资源计数。

4、事件对象: 通过通知操作的方式来保持线程的同步,还可以方便实现对多个线程的优先级比较的操作

总结下事件Event
1)事件是内核对象,事件分为手动置位事件和自动置位事件。事件Event内部它包含一个使用计数(所有内核对象都有),一个布尔值表示是手动置位事件还是自动置位事件,另一个布尔值用来表示事件有无触发。
2)事件可以由SetEvent()来触发,由ResetEvent()来设成未触发。还可以由PulseEvent()来发出一个事件脉冲。
3)事件可以解决线程间同步问题,因此也能解决互斥问题。

三,四种线程同步控制方式

1,互斥对象

第一个CreateMutex
函数功能:创建互斥量(注意与事件Event的创建函数对比)
函数原型:

HANDLE  CreateMutex(
    LPSECURITY_ATTRIBUTES  lpMutexAttributes,
    BOOL  bInitialOwner, 
    LPCTSTR  lpName
);

函数说明:
第一个参数表示安全控制,一般直接传入NULL。
第二个参数用来确定互斥量的初始拥有者。如果传入TRUE表示互斥量对象内部会记录创建它的线程的线程ID号并将递归计数设置为1,由于该线程ID非零,所以互斥量处于未触发状态。如果传入FALSE,那么互斥量对象内部的线程ID号将设置为NULL,递归计数设置为0,这意味互斥量不为任何线程占用,处于触发状态。
第三个参数用来设置互斥量的名称,在多个进程中的线程就是通过名称来确保它们访问的是同一个互斥量。
函数访问值:
成功返回一个表示互斥量的句柄,失败返回NULL。


第二个打开互斥量
函数原型:

HANDLE  OpenMutex(
    DWORD   dwDesiredAccess,
    BOOL  bInheritHandle,
    LPCTSTR  lpName //名称
);

函数说明:
第一个参数表示访问权限,对互斥量一般传入MUTEX_ALL_ACCESS。详细解释可以查看MSDN文档。
第二个参数表示互斥量句柄继承性,一般传入TRUE即可。
第三个参数表示名称。某一个进程中的线程创建互斥量后,其它进程中的线程就可以通过这个函数来找到这个互斥量。
函数访问值:
成功返回一个表示互斥量的句柄,失败返回NULL。


第三个触发互斥量
函数原型:
BOOL  ReleaseMutex (HANDLE  hMutex)
函数说明:
访问互斥资源前应该要调用等待函数,结束访问时就要调用ReleaseMutex()来表示自己已经结束访问,其它线程可以开始访问了。


最后一个清理互斥量
由于互斥量是内核对象,因此使用CloseHandle()就可以(这一点所有内核对象都一样)。

互斥对象的形象比喻:

首先我们需要创建CreateMutex一把互斥对象,我们可以指明当前线程是否拥有它,互斥对象完全就像一把钥匙一样,我们用WaitForSignalObject来等待这把钥匙,但是这把钥匙被等到并且使用后必须释放-----ReleaseMutex ,不然别人永远无法等到。这样从等待到释放中间的代码段永远都是只有一个线程在执行,也就形成了互斥控制。当然互斥对象的句柄是要关闭的CloseHandle。

结合下面的程序理解简直轻松。

互斥对象模拟火车售票的过程

(对共同资源的互斥控制)

#include "windows.h"  
#include "iostream"  
  
using namespace std;  
  
DWORD WINAPI FunProc1(LPVOID lpParameter);  
DWORD WINAPI FunProc2(LPVOID lpParameter);  
  
int ticket = 100;  
HANDLE hMutex;   //定义互斥对象  
int main()  
{  
    HANDLE hThread1;  
    HANDLE hThread2;  
    hMutex = CreateMutex(NULL, FALSE, NULL);    //创建互斥对象,并且该线程不拥有他(因为第二个参数为false)  
    hThread1 = CreateThread(NULL, 0, FunProc1, NULL, 0, NULL);  
    hThread2 = CreateThread(NULL, 0, FunProc2, NULL, 0, NULL);  
    CloseHandle(hThread1);  
    CloseHandle(hThread2);  
    Sleep(1000);// 让主线程睡眠1秒 ,不然子线程来不及执行  
    return 0;  
}  
  
DWORD WINAPI FunProc1(LPVOID lpParameter)  
{  
    while (TRUE)  
    {  
        WaitForSingleObject(hMutex, INFINITE);   //申请互斥对象的所有权(申请钥匙,得到钥匙)  
        if (ticket>0)  
        {  
            Sleep(1);  
            cout << "ticket 1:" << ticket-- << endl;  
        }  
        else  
            break;  
        ReleaseMutex(hMutex);//释放互斥对象的所有权(放弃钥匙,不再拥有)  
    }  
    return 0;  
}  
DWORD WINAPI FunProc2(LPVOID lpParameter)  
{  
    while (TRUE)  
    {  
        WaitForSingleObject(hMutex, INFINITE);  
        if (ticket>0)  
        {  
            Sleep(1);  
            cout << "ticket 2:" << ticket-- << endl;  
        }  
        else  
            break;  
        ReleaseMutex(hMutex);  
    }  
    return 0;  
}  

分析程序互斥过程

创建互斥对象后,第二各参数是false表示当前主线程不拥有互斥对象,此时互斥对象没人拥有,所以谁都可以获取他,然后主线程空闲1秒(子线程才时间执行,不然主线程一下就退出了),在这一秒内第一个线程waitforsingleobject得到了互斥对象(不然无法执行),开始卖火车票,然后释放互斥对象的拥有权,接着第二个线程通过waitforsingleobject得到了互斥对象,所以他又可以执行售卖火车票,接着释放互斥对象...如此往返!知道火车票卖完,while循环退出。

注意:虽然改程序运行结果是某一条线程执行完然后第二条线程执行,如此往复,但是这不是同步,因为我们没法控制到底一开始是谁先执行,(我们只是控制了轮流次序)。

2,事件对象

第一个 CreateEvent
函数功能:创建事件
函数原型:

HANDLE  CreateEvent(
    LPSECURITY_ATTRIBUTES   lpEventAttributes,
    BOOL   bManualReset,
    BOOL   bInitialState,
    LPCTSTR  lpName
);


函数说明:
第一个参数表示安全控制,一般直接传入NULL。
第二个参数确定事件是手动置位还是自动置位,传入TRUE表示手动置位,传入FALSE表示自动置位。如果为自动置位,则对该事件调用WaitForSingleObject()后会自动调用ResetEvent()使事件变成未触发状态。
第三个参数表示事件的初始状态,传入TRUR表示已触发。
第四个参数表示事件的名称,传入NULL表示匿名事件。



第二个 OpenEvent
函数功能:根据名称获得一个事件句柄。
函数原型:

HANDLE  OpenEvent(
    DWORD  dwDesiredAccess,
    BOOL  bInheritHandle,
    LPCTSTR  lpName //名称
);

函数说明:
第一个参数表示访问权限,对事件一般传入EVENT_ALL_ACCESS。详细解释可以查看MSDN文档。
第二个参数表示事件句柄继承性,一般传入TRUE即可。
第三个参数表示名称,不同进程中的各线程可以通过名称来确保它们访问同一个事件。


第三个SetEvent
函数功能:触发事件
函数原型:BOOL   SetEvent(HANDLE  hEvent);
函数说明:每次触发后,必有一个或多个处于等待状态下的线程变成可调度状态。


第四个ResetEvent
函数功能:将事件设为末触发
函数原型:BOOLResetEvent(HANDLEhEvent);


最后一个事件的清理与销毁
由于事件是内核对象,因此使用CloseHandle()就可以完成清理与销毁了。

事件对象的形象比喻:

首先我们需要创建CreateEvent一个事件对象,它的使用方式是触发方式,要想被WaitForSingleObject等待到该事件对象必须是有信号的,事件要想有信号可以用SetEvent手动置为有信号,要想事件对象无信号可以使用ResetEvent(或者在创建事件对象时就声明该事件对象WaitForSingleObject后自动置为无信号,见上面CreateEvent第二个参数),打个小小比方,手动置位事件相当于教室门,教室门一旦打开(被触发),所以有人都可以进入直到老师去关上教室门(事件变成未触发)。自动置位事件就相当于医院里拍X光的房间门,门打开后只能进入一个人,这个人进去后会将门关上,其它人不能进入除非门重新被打开(事件重新被触发)。当然事件对象的句柄是要关闭的CloseHandle。

结合下面的程序理解简直轻松。

事件对象模拟火车售票的过程

(利用通知的方式对共同资源的互斥控制)

#include "windows.h"  
#include "iostream"  
  
using namespace std;  
  
DWORD WINAPI FunProc1(LPVOID lpParameter);  
DWORD WINAPI FunProc2(LPVOID lpParameter);  
int ticket = 100;  
HANDLE g_hEvent;  

void main()  
{  
    HANDLE hThread1;  
    HANDLE hThread2;  
    g_hEvent = CreateEvent(NULL, FALSE, TRUE, NULL);      //创建事件对象  
    //SetEvent(g_hEvent);           //设置为有信号(放弃钥匙)  
    hThread1 = CreateThread(NULL, 0, FunProc1, NULL, 0, NULL);  
    hThread2 = CreateThread(NULL, 0, FunProc2, NULL, 0, NULL);  
    CloseHandle(hThread1);  
    CloseHandle(hThread2);  
    Sleep(1000);             // 让主线程睡眠1秒   
    CloseHandle(g_hEvent);  
}  

DWORD WINAPI FunProc1(LPVOID lpParameter)  
{  
    while (TRUE)  
    {  
        WaitForSingleObject(g_hEvent, INFINITE);     //申请事件对象  
        //ResetEvent(g_hEvent);       //重置为无信号(申请钥匙,得带钥匙)  
        if (ticket>0)  
        {  
            Sleep(1);  
            cout << "ticket 1:" << ticket-- << endl;  
            SetEvent(g_hEvent);     //设置为有信号(放弃钥匙,不再拥有)  
        }  
        else  
        {  
            SetEvent(g_hEvent);      //设置为有信号  
            break;  
        }  
    }  
    return 0;  
}  

DWORD WINAPI FunProc2(LPVOID lpParameter)  
{  
    while (TRUE)  
    {  
        WaitForSingleObject(g_hEvent, INFINITE);  
        //ResetEvent(g_hEvent);  
        if (ticket>0)  
        {  
            Sleep(1);  
            cout << "ticket 2:" << ticket-- << endl;  
            SetEvent(g_hEvent);       //设置为有信号  
        }  
        else  
        {  
            SetEvent(g_hEvent);       //设置为有信号  
            break;  
        }  
    }  
    return 0;  
} 

同步过程分析

g_hEvent=CreateEvent(NULL,FALSE,TRUE,NULL);的意义(顺序解释):默认安全性,自动重置事件,初始时该事件对象就有信号。执行顺序:开始的时候事件对象具有信号,当第一个线程申请获得事件对象后,进入if语句线程1会暂停1毫秒,于是第二根线程运行,因为此时g_hEvent已经无信号故无法申请并执行下面的程序,此时第一个线程睡醒开始执行自己的任务然后设置对象为有信号(可以被其他线程申请),于是第二个线程申请得到事件对象................与此往复!直到退出循环。

注意:该程序实现的不是的同步控制!但是他可以实现同步,见下面!

下面这种事件通知方式就是严格的同步方式(先让线程1执行,再.....),两个事件对象进行同步控制:

#include "windows.h"    
#include "iostream"    
  
using namespace std;  
  
DWORD WINAPI FunProc1(LPVOID lpParameter);  
DWORD WINAPI FunProc2(LPVOID lpParameter);  
int ticket = 100;  
HANDLE g_hEvent1,g_hEvent2;  
  
void main()  
{  
    HANDLE hThread1;  
    HANDLE hThread2;  
    g_hEvent1 = CreateEvent(NULL, FALSE, TRUE, NULL);      //创建事件对象1,自动重置事件,已触发  
    g_hEvent2 = CreateEvent(NULL, FALSE, FALSE, NULL);      //创建事件对象2,自动重置事件,没触发  
    //SetEvent(g_hEvent);           //设置为有信号(放弃钥匙)    
    hThread1 = CreateThread(NULL, 0, FunProc1, NULL, 0, NULL);  
    hThread2 = CreateThread(NULL, 0, FunProc2, NULL, 0, NULL);  
    CloseHandle(hThread1);  
    CloseHandle(hThread2);  
    Sleep(1000);             // 让主线程睡眠1秒     
    CloseHandle(g_hEvent1);  
    CloseHandle(g_hEvent2);  
    getchar();  
}  
DWORD WINAPI FunProc1(LPVOID lpParameter)  
{  
    while (TRUE)  
    {  
        WaitForSingleObject(g_hEvent1, INFINITE);     //申请有信号的事件对象    
        //ResetEvent(g_hEvent);       //重置为无信号(申请钥匙,得带钥匙)    
        if (ticket>0)  
        {  
            Sleep(1);  
            cout << "ticket 1:" << ticket-- << endl;  
            SetEvent(g_hEvent2);     //设置为有信号(放弃钥匙,不再拥有)    
        }  
        else  
        {  
            SetEvent(g_hEvent2);      //设置为有信号,让线程2执行  
            break;  
        }  
    }  
    return 0;  
}  
DWORD WINAPI FunProc2(LPVOID lpParameter)  
{  
    while (TRUE)  
    {  
        WaitForSingleObject(g_hEvent2, INFINITE);  
        //ResetEvent(g_hEvent);    
        if (ticket>0)  
        {  
            Sleep(1);  
            cout << "ticket 2:" << ticket-- << endl;  
            SetEvent(g_hEvent1);  //让线程1执行  
        }  
        else  
        {  
            SetEvent(g_hEvent1);         
            break;  
        }  
    }  
    return 0;  
}  

3,临界区(关键代码段)

函数功能:初始化
函数原型:
void InitializeCriticalSection(LPCRITICAL_SECTION  lpCriticalSection);
函数说明:定义关键段变量后必须先初始化。


函数功能:销毁
函数原型:
void DeleteCriticalSection(LPCRITICAL_SECTION  lpCriticalSection);
函数说明:用完之后记得销毁。


函数功能:进入关键区域
函数原型:
void EnterCriticalSection(LPCRITICAL_SECTION  lpCriticalSection);
函数说明:系统保证各线程互斥的进入关键区域。


函数功能:离开关关键区域
函数原型:
void LeaveCriticalSection(LPCRITICAL_SECTION  lpCriticalSection);

临界区模拟火车售票的过程

添加代码如下

#include "windows.h"  
#include "iostream"  
  
using namespace std;  
  
DWORD WINAPI FunProc1(LPVOID lpParameter);  
DWORD WINAPI FunProc2(LPVOID lpParameter);  
int ticket = 100;  
CRITICAL_SECTION g_cs;     //定义临界区  
void main()  
{  
    HANDLE hThread1;  
    HANDLE hThread2;  
    InitializeCriticalSection(&g_cs);    //必须先初始化临界区  
    hThread1 = CreateThread(NULL, 0, FunProc1, NULL, 0, NULL);  
    hThread2 = CreateThread(NULL, 0, FunProc2, NULL, 0, NULL);  
    CloseHandle(hThread1);  
    CloseHandle(hThread2);  
    Sleep(1000);// 让主线程睡眠1秒   
    DeleteCriticalSection(&g_cs);     //删除临界区  
}  
DWORD WINAPI FunProc1(LPVOID lpParameter)  
{  
    while (TRUE)  
    {  
        EnterCriticalSection(&g_cs);//进入临界区(申请钥匙,得到钥匙)  
        Sleep(1);  
        if (ticket>0)  
        {  
            Sleep(1);  
            cout << "ticket 1:" << ticket-- << endl;  
            LeaveCriticalSection(&g_cs);   //离开(放弃钥匙,不再拥有)  
        }  
        else  
        {  
            LeaveCriticalSection(&g_cs);    //离开  
            break;  
        }  
    }  
    return 0;  
}  
DWORD WINAPI FunProc2(LPVOID lpParameter)  
{  
    while (TRUE)  
    {  
        EnterCriticalSection(&g_cs);      
        if (ticket>0)  
        {  
            Sleep(1);  
            cout << "ticket 2:" << ticket-- << endl;  
            LeaveCriticalSection(&g_cs);     
        }  
        else  
        {  
            LeaveCriticalSection(&g_cs);    
            break;  
        }  
    }  
    return 0;  
}  

4,信号量

信号量Semaphore常用有三个函数,使用很方便。下面是这几个函数的原型和使用说明。

HANDLE   CreateSemaphore( 
    LPSECURITY ATTRIBUTES   lpSemaphoreAttributes, //安全属性 
    LONG   lInitialCount, //信号量对象的初始值 
    LONG   lMaximumCount, //信号量的最大值 
    LPCTSTR   lpName //信号量名 
); 

参数说明: 
(1)lpSemaphoreAttributes:指定安全属性,为NULL时,信号量得到一个 
默认的安全描述符。 
(2) lInitialCount:指定信号量对象的初始值。该值必须大于等于0,小于等于lMaximumCount。当其值大于0时,信号量被唤醒。当该函数释放了一个等待该信号量的线程时,lInitialCount值减1,当调用函数ReleaseSemaphore()时,按其指定的数量加一个值。
(3) lMaximumCount:指出该信号量的最大值,该值必须大于0。 
(4) lpName:给出信号量的名字。 
返回值: 
信号量创建成功,将返回该信号量的句柄。如果给出的信号量名是系统已经存在的信号量,将返回这个已存在信号量的句柄。如果失败,系统返回NULL,可以调用函数GetLastError()查询失败的原因



第二个 OpenSemaphore
函数功能:打开信号量
函数原型:

HANDLE  OpenSemaphore(
    DWORD  dwDesiredAccess,
    BOOL  bInheritHandle,
    LPCTSTR  lpName
);

函数说明:
第一个参数表示访问权限,对一般传入SEMAPHORE_ALL_ACCESS。详细解释可以查看MSDN文档。
第二个参数表示信号量句柄继承性,一般传入TRUE即可。
第三个参数表示名称,不同进程中的各线程可以通过名称来确保它们访问同一个信号量。


第三个 ReleaseSemaphore
函数功能:递增信号量的当前资源计数
函数原型:

BOOL  ReleaseSemaphore(
    HANDLE  hSemaphore,
    LONG  lReleaseCount, 
    LPLONG  lpPreviousCount 
);


函数说明:
第一个参数是信号量的句柄。
第二个参数表示增加个数,必须大于0且不超过最大资源数量。
第三个参数可以用来传出先前的资源计数,设为NULL表示不需要传出。

注意:当前资源数量大于0,表示信号量处于触发,等于0表示资源已经耗尽故信号量处于末触发。在对信号量调用等待函数时,等待函数会检查信号量的当前资源计数,如果大于0(即信号量处于触发状态),减1后返回让调用线程继续执行。一个线程可以多次调用等待函数来减小信号量。

最后一个 信号量的清理与销毁
由于信号量是内核对象,因此使用CloseHandle()就可以完成清理与销毁了。

信号量超形象解释:

以一个停车场的运作为例。简单起见,假设停车场只有三个车位(共有资源),一开始三个车位都是空的。这时如果同时来了五辆车(线程),看门人(信号量)允许其中三辆(线程)直接进入,然后放下车拦,剩下的车则必须在入口等待,此后来的车也都不得不在入口处等待。这时,有一辆车(线程)离开停车场,看门人(信号量)得知后,打开车拦,放入外面的一辆进去,如果又离开两辆,则又可以放入两辆,如此往复。
抽象的来讲,信号量的特性如下:信号量是一个非负整数(车位数),所有通过它的线程/进程(车辆)都会将该整数减一(通过它使得资源被使用了1个),当该整数值为零时,所有试图通过它的线程(车辆)都将处于等待状态。在信号量上我们定义两种操作: Wait(等待函数) 和 Release(释放函数)。当一个线程调用Wait操作时,它要么得到资源然后将信号量减一,要么一直等下去(指放入阻塞队列),直到信号量大于等于一时。Release(释放)对应于车辆离开停车场,该操作之所以叫做“释放”是因为释放了由信号量守护的资源(车位)。

参考学习例子:

#include <stdio.h>  
#include <process.h>  
#include <windows.h>  
  
long g_nNum;  
unsigned int __stdcall Fun(void *pPM);  
const int THREAD_NUM = 10;  
//信号量与关键段  
HANDLE            g_hThreadParameter;//用信号量处理主线程与子线程的同步  
CRITICAL_SECTION  g_csThreadCode;//关键段来处理各子线程间的互斥.对公有资源进行互斥访问,公有资源g_nNum  
  
int main()  
{  
    //初始化信号量和关键段  
    g_hThreadParameter = CreateSemaphore(NULL, 0, 1, NULL);//第二个参数表示初始资源数量。当前0个资源,最大允许1个同时访问  
    InitializeCriticalSection(&g_csThreadCode);  
  
    HANDLE  handle[THREAD_NUM];  
    g_nNum = 0;  
    int i = 0;  
    while (i < THREAD_NUM)  
    {  
        handle[i] = (HANDLE)_beginthreadex(NULL, 0, Fun, &i, 0, NULL);  
        Sleep(1);  
        WaitForSingleObject(g_hThreadParameter, INFINITE);//依次使线程进入等待状态(阻塞队列)。参见《windows核心编程第五版》  
        ++i;  
    }  
  
    WaitForMultipleObjects(THREAD_NUM, handle, TRUE, INFINITE);  
  
    DeleteCriticalSection(&g_csThreadCode);  
    //销毁信号量和关键段  
    CloseHandle(g_hThreadParameter);  
    for (i = 0; i < THREAD_NUM; i++)  
        CloseHandle(handle[i]);  
      
    getchar();  
    return 0;  
}  
unsigned int __stdcall Fun(void *pPM)  
{  
    int nThreadNum = *(int *)pPM;  
    ReleaseSemaphore(g_hThreadParameter, 1, NULL);//信号量的当前资源+1,第二个参数表示增加个数,必须大于0且不超过最大资源数量。  
    Sleep(50);//some work should to do  
    EnterCriticalSection(&g_csThreadCode);  
    ++g_nNum;  
    Sleep(10);//some work should to do  
    printf("线程编号为%d  全局资源值为%d\n", nThreadNum, g_nNum);  
    LeaveCriticalSection(&g_csThreadCode);  
    return 0;  
}  


 

收录博文:

1. 并发:在操作系统中,是指一个时间段中有几个程序都处于已启动运行到运行完毕之间,且这几个程序都是在同一个处理机上运行。其中两种并发关系分别是同步和互斥


2. 互斥:进程间相互排斥的使用临界资源的现象,就叫互斥。


3. 同步:进程之间的关系不是相互排斥临界资源的关系,而是相互依赖的关系。进一步的说明:就是前一个进程的输出作为后一个进程的输入,当第一个进程没有输出时第二个进程必须等待。具有同步关系的一组并发进程相互发送的信息称为消息或事件。其中并发又有伪并发和真并发,伪并发是指单核处理器的并发,真并发是指多核处理器的并发。


4. 并行:在单处理器中多道程序设计系统中,进程被交替执行,表现出一种并发的外部特种;在多处理器系统中,进程不仅可以交替执行,而且可以重叠执行。在多处理器上的程序才可实现并行处理。从而可知,并行是针对多处理器而言的。并行是同时发生的多个并发事件,具有并发的含义,但并发不一定并行,也亦是说并发事件之间不一定要同一时刻发生。

5. 多线程:多线程是程序设计的逻辑层概念,它是进程中并发运行的一段代码。多线程可以实现线程间的切换执行。

6. 异步:异步和同步是相对的,同步就是顺序执行,执行完一个再执行下一个,需要等待、协调运行。异步就是彼此独立,在等待某事件的过程中继续做自己的事,不需要等待这一事件完成后再工作。线程就是实现异步的一个方式。异步是让调用方法的主线程不需要同步等待另一线程的完成,从而可以让主线程干其它的事情。
异步和多线程并不是一个同等关系,异步是最终目的,多线程只是我们实现异步的一种手段。异步是当一个调用请求发送给被调用者,而调用者不用等待其结果的返回而可以做其它的事情。实现异步可以采用多线程技术或则交给另外的进程来处理。


为了对以上概念的更好理解举一个简单例子, 

 假设我要做 烧开水,举杠铃100下, 洗衣服 3件事情。

烧开水 这件事情, 我要做的事情为, 准备烧开水 1分钟, 等开水烧开 8 分钟 , 关掉烧水机 1分钟
举杠铃100下 我要做的事情为, 举杠铃100下 10分钟
洗衣服 我要做的事情为, 准备洗衣服 1分钟, 等开水烧开 5 分钟 , 关掉洗衣机 1分钟

单核情况下
同步的完成,我需要做的时间为 1+ 8 +1 + 10 + 1+ 5 +1 = 27 分

如果异步,就是在等的时候,我可以切换去做别的事情

准备烧开水(1) + 准备洗衣服(1) + 举50下杠铃 (5)分钟+ 关洗衣机 1分钟 + 举杠铃20下 (2)分钟+ 关烧水机 1分钟 + 举30下杠铃(3)分钟
1+1+5+1+2+1+3 =14 分钟


双核 异步 并行

核1 准备烧开水 1分钟+ 举杠铃50下(5)分钟+ 等待3分钟 + 关掉烧水机 1分钟

核2 准备洗衣服 1分钟+ 举杠铃50下(5)分钟+ 关掉洗衣机 1分钟 + 等待3分钟

其实只花了 1+5+3+1 = 10分钟

其中还有双核都等待了3分钟
双核 异步 非并行

核1 举杠铃100下(10)分钟

核2 准备烧开水 1分钟+ 准备洗衣服 1分钟+ 等待5 分钟+ + 关掉烧水机 1分钟 + 等待 1 分钟 + 关掉洗衣机 1分钟

其实只花了 1+5+3+1 = 10分钟
多线程的做法
单核下

线程1 准备烧开水 1分钟, 等开水烧开 8 分钟 , 关掉烧水机 1分钟
线程2 举杠铃100下 10分钟
线程3 准备洗衣服 1分钟, 等开水烧开 5 分钟 , 关掉洗衣机 1分钟

cpu 可能这么切换 最理想的切换方式

线程1 准备烧开水1 sleep 1 sleep 5 sleep 1 sleep 2 关开水 1分钟 exit
线程2 sleep 1 sleep 1 举杠铃50 5分钟 sleep 1 举杠铃20 2分钟 sleep1 举杠铃30下 3分钟 
线程3 sleep 1 准备洗衣服1 分钟 sleep 5 关洗衣机1分钟 exit

最后使用了 14分钟 和异步是一样的。
但是实际上是不一样的,因为线程不会按照我们设想的去跑, 如果线程2 举杠铃先跑,整个流程的速度就下来了。

异步和同步的区别, 在io等待的时候,同步不会切走,浪费了时间。

如果都是独占cpu 的业务, 比如举杠铃的业务, 在单核情况下 多线和单线 没有区别。

多线程的好处,比较容易的实现了 异步切换的思想, 因为异步的程序很难写的。多线程本身程还是以同步完成,但是应该说
比效率是比不上异步的。 而且多线很容易写, 相对效率也高。

多核的好处,就是可以同时做事情, 这个和单核完全不一样的。

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

线程同步的四种方式 的相关文章

  • 1.语音增强技术概述

    一 语音增强发展历史 1987年 xff1a Lim和Oppenheim发表语音增强的维纳滤波方法 xff1b 1987年 xff1a Boll发表谱减法 xff1b 1980年 xff1a Maulay和Malpass提出软判决噪声一直方
  • PCB软件对比分析(AD、Pads、Allegro)

    文章目录 前言一 国内的EDA软件市场二 Altium三 Mentor四 Candence总结 前言 今天来说一说国内用的最多的三款PCB软件对比 一 国内的EDA软件市场 国内的EDA软件几乎被三家瓜分 1 Altium 2 Canden
  • (二)立创EDA之新建工程,原理图,PCB

    文章目录 前言一 界面介绍二 工程广场介绍三 新建工程3 1 修改图纸属性 四 基本的操作介绍4 1 添加器件4 2 连接导线4 3 添加插针4 4 查看封装4 5 修改封装 五 原理图转PCB5 1设置PCB高亮显示元器件5 2 布局传递
  • stm32mp157 wm8960音频驱动调试笔记

    这次调试wm8960音频驱动遇到了好多的坑 xff0c 研究好几天终于调试好了 驱动调试步骤 驱动能不能成功加载是调试的第一大步骤 xff0c 也是最关键的步骤之一 1 查看硬件原理图 2 打开对应的设备树 xff08 stm32mp157
  • ROS发布者(Publisher)和订阅者(Subscriber)的python编程实现(讲解超级详细)

    有时候想想 xff0c 国内有些资源确实比较稀缺 xff0c 但是我们一样不会落后 xff01 学习python和ROS这么久了 xff0c 一直很少去实战 xff0c 另外看到基于python编程的ROS话题通信教程实在是稀缺了 xff0
  • C#工控上位机——框架

    C 工控上位机 第一部分 xff1a UI模块 先点击一下Panel xff0c 在点击一下屏幕 先选中Panel xff0c 在进行属性设置 图标连接 嵌入式窗体 设置按键的事件 using
  • docker镜像启动es/kibana

    下载镜像elasticsearch docker search elasticsearch docker pull elasticsearch 启动镜像 docker run name my elasticsearch p 9200 920
  • 虚拟串口的使用

    虚拟串口的使用
  • 修改闭包内使用的外部变量

    修改闭包内使用的外部变量的错误示例 定义一个外部函数 def func out num1 定义一个内部函数 def func inner num2 这里本意想要修改外部num1的值 xff0c 实际上是在内部函数定义了一个局部变量num1
  • 嵌入式软件面试题

    CSDN的小伙伴们 xff0c 我是林君 今天给小伙伴们分享一些嵌入式软件开发工程师的校招面试题 企业校招对基础考察较多 其次 xff0c 在校参加的相关比赛 xff0c 项目经历 我在生病前 xff0c 面试了一周 xff0c 收到八九个
  • 嵌入式软件工程师技术等级

    1 初级 xff1a 8051或其他单片机 xff0c UCOS xff0c I C xff0c SPI xff0c UART 汇编和C语言能力一般 xff0c 系统集成能力弱 2 中级 xff1a 在初级的基础上 xff0c ARM MI
  • FreeRTOS之动态方法任务创建和删除实验

    一 实验设计 start task xff1a 用来创建其他两个任务 task1 task 当此任务运行5次就调用vTaskDelete 删除任务task2 task task2 task 此任务为普通的应用任务 一 宏定义 任务优先级 d
  • 人工智能研究主要有哪三大学派,其特点是什么?

    人工智能研究主要有哪三大学派 xff0c 其特点是什么 xff1f xff08 1 xff09 符号主义 xff1a 又称为功能模拟学派 xff0c 主要观点认为智能活动的基础是物理符号系统 xff0c 思维过程是符号模式的处理过程 其特点
  • FreeRTOS入门

    目录 一 任务要求二 FreeRTOS移植1 简介2 参考教程3 多任务程序管理实现4 执行结果 三 总结 一 任务要求 在STM32下完成一个基于FreeRTOS的多任务程序 xff0c 执行3个周期性task xff0c 具体任务不限
  • 2021年全国大学生电子设计大赛F题——智能送药小车,全方位解决方案+程序代码(详细注释)山东赛区国奖

    目录 1 赛题及硬件方案分析 xff1a 2 用到的主要器件清单 xff1a 3 各部分思路及代码实现 1 小车舵机 马达驱动 2 蓝牙通信 3 单片机与OpenMV的串口通信 4 单片机与OpenMV的通信协议 5 单片机main文件中的
  • C++学习小记之代码重用问题(1)

    C 43 43 Primer Plus第六版第14章程序清单14 2给的示例代码中有以下两段代码 xff1a double amp Student operator int i return scores i double Student
  • 出现“ ‘xxx‘ 不是内部或外部命令,也不是可运行的程序 或批处理文件。”的一个解决方法

    XXX 不是内部或外部命令 xff0c 也不是可运行的程序或批处理文件 前提是已经安装成功某一个插件 有时候 xff0c 我们想用cmd xff08 以管理员身份运行 xff09 执行命令的时候 xff0c 总会出现 XXX 不是内部或外部
  • RK算法分析

    这一节介绍一下由Rabin和Karp提出的RK算法 1 xff0c RK算法的基本思想 HASH xff01 如果两个字符串hash后的值不相同 xff0c 则它们肯定不相同 xff1b 如果它们hash后的值相同 xff0c 它们不一定相
  • Xilinx ZYNQ FreeRTOS+Tracealyzer(移植)

    PL端配置 使用ZYNQ IP Core 打开串口 网口等所需接口 新手注意 xff1a 需要生成bit文件后 xff0c 并输出相应硬件平台 xff0c 网上教程很多 xff0c 请参考其它教程 PS端配置 1 创建任务 xff0c 注意
  • Openmv学习day2——AprilTag

    仅作为个人学习 xff0c 原文地址 xff1a 链接 link AprilTag的简介 AprilTag是一个视觉基准系统 xff0c 可用于各种任务 xff0c 包括AR xff0c 机器人和相机校准 这个tag可以直接用打印机打印出来

随机推荐

  • JS进行简单的表单验证(附详细代码)

    提示 xff1a 文章写完后 xff0c 目录可以自动生成 xff0c 如何生成可参考右边的帮助文档 文章目录 一 JS表单验证是什么 xff1f 一 JS表单验证需求分析 xff1f 三 表单验证所需事件设置from表单及其文本框 xff
  • FreeRTOS学习(三)FreeRTOS任务基础知识

    FreeRTOS任务基础知识 1 FreeRTOS任务特性2 FreeRTOS的任务状态3 任务优先级4 任务调度方式5 任务控制块6 任务堆栈 1 FreeRTOS任务特性 特性1 xff1a 任务数量没有限制 xff0c 想要创建多少个
  • 如何写串口通信

    1 初始化串口 void USART INIT void GPIO InitTypeDef GPIO InitStructure 使能USART1 RCC APB2PeriphClockCmd RCC APB2Periph USART1 E
  • 树莓派WiFi连接问题及网页打开问题的解决

    树莓派WiFi连接问题及网页打开问题的解决 一 问题描述 前一段时间在网上买了一个树莓派 4b计划做一个人脸识别的智能锁 xff0c 前一段时间整赶上期末考试 xff0c 挤时间做了做人脸识别以及人体红外感知模块 xff0c 大致能简单实现
  • windows双系统如何删除ubuntu系统并重装

    电脑装有windows和Ubuntu双系统 xff0c 当需要重装Ubuntu时 xff0c 需要先卸载掉已经安装的Ubuntu系统 博主电脑安装的是Windows10和Ubuntu20 04LTS 现在需要卸载Ubuntu20 04 xf
  • 全网最全的MCU面试经(基于STM32F103)

    免责声明 提示 xff1a 写本文章的缘由 xff1a 本人在秋招时复习STM32有关的知识点 xff0c 便顺势记录下来 本文章的知识均属于各大论坛的大佬回答 xff0c 其中也有我的一些补充 xff0c 本文主要以自己对STM32的理解
  • Quartus II和Modelsim初学踩坑笔记

    Quartus II和Modelsim初学踩坑笔记 1 软件安装 网上有关软件安装的教程已经足够多了 xff0c 这里不再赘述 xff0c 但我要提醒的一点是 xff0c 不要把软件和之后创建的项目工程放在中文路径下面 本文使用的软件环境是
  • HDLBits刷题记录--Modules:Hierarchy

    HDLBits刷题记录 Modules Hierarchy Module 电路图 xff1a 代码 xff1a module top module span class token punctuation span input a span
  • C++中SORT函数使用方法

    一 sort函数 1 sort函数包含在头文件为 include lt algorithm gt 的c 43 43 标准库中 xff0c 调用标准库里的排序方法可以实现对数据的排序 xff0c 但是sort函数是如何实现的 xff0c 我们
  • Window下LaTex+VS Code的配置

    目录 前言 一 软件下载二 软件安装1 TexLive安装2 VS Code及插件安装 三 配置 VS Code四 简单测试一下五 进阶操作及可能遇到的问题1 前向搜索和反向搜索2 编译带参考文献的 tex文件 前言 考虑本文受众有新手小白
  • 与 vmx86 驱动程序的版本不匹配解决方法

    一个新手可能遇到的问题 第一次安装完VMware后 xff0c 启动时可能会遇到问题 xff1a 与 vmx86 驱动程序的版本不匹配 预期为xxx 实际为 xxx 驱动程序 vmx86 sys的版本不正确 如下图 xff1a 解决方法 x
  • 汽车电子系统知识积累

    文章目录 前言一 汽车电子系统的分类1 电子控制汽车电子控制系统2 电子控制车载汽车电子系统 二 分类及详述1 动力2 底盘3 车身4 娱乐 总结 前言 汽车电子系统是以汽车电子技术为基础的汽车结构 一 汽车电子系统的分类 按照电子系统对汽
  • Jetson Xavier NX 学习(一),安装sd卡镜像

    Jetson Xavier NX 学习 xff08 一 xff09 xff0c 安装sd卡镜像 说明个人说明了解JetPack SDK下载镜像将图像写入microSD卡启动查看设置 说明 Jetson Xavier NX可为运行现代AI工作
  • 服务器ssh远程连接失败

    服务器远程ssh连接失败解决方案 查看ssh服务状态 systemctl status sshd service 正常应该是下图情况 xff1a xff08 running xff09 绿色即为正常状态 在这里插入图片描述 如果正常查看后面
  • Day1--FreeRTOS简介及多任务点灯、多任务传参、Mutex

    实时操作系统 xff08 Real Time Operating System xff0c 简称RTOS xff09 Arduino任务执行流程 xff1a 单线程执行任务 RTOS xff1a 可以同时执行所有Task xff0c 每个任
  • Day3--流媒体缓存、消息缓存(重要)、直接任务通知

    FreeRTOS 10以后引入了一个新的数据类型就是 Stream Buffer 它和Queue最大的不同就是 xff0c Stream Buffer读写的大小没有限制 xff0c 而Queue是预设值好固定的值 Stream Buffer
  • 51安居安防手电筒拆解

    51安居安防手电筒拆解 相遇就是缘分 xff0c 欢迎 51安居这款手电筒有照明LED灯 安全锤 强力磁铁 手摇发电机 应急闪光灯 FM收音机 警报喇叭等非常多的功能 xff0c 但是自己维修比较困难 我的长辈在外面买了51安防的手电筒 x
  • 关于keil和proteus联调失败的原因探究

    1 没有在两个软件文件夹下放置 dll文件 没有在C51的INI文件中修改 2 没有安装某个 exe文件 3 在proteus中建好电路 xff0c 把keil生成的hex文件导入芯片 xff0c debug xff0c 打开远程调试 xf
  • 富斯遥控器/接收机的PWM/PPM/iBUS/SBUS通道设置

    富斯遥控器FS i6X拥有10通道输出 xff0c 富斯接收机FS iA10B拥有10通道输入 xff0c 两者都有PWM PPM iBUS SBUS协议 xff0c 但是PPM和iBUS协议最高只支持8通道 xff0c 而SBUS协议可以
  • 线程同步的四种方式

    一 xff0c 什么是线程同步和互斥 同步就是协同步调 xff0c 按预定的先后次序进行运行 如 xff1a 你说完 xff0c 我再说 这里的同步千万不要理解成那个同时进行 xff0c 应是指协同 协助 互相配合 线程同步是指多线程通过特