线程同步的四种方式

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(使用前将#替换为@)

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

  • 长虹官方刷机包和刷机教程

    为了解决部分朋友因应用引起的电视死机 无法开机 系统被破坏等情形 xff0c 长虹电视团队特开此帖为朋友们提供刷机方法 xff0c 但刷机有风险 xff0c 如完全不懂刷机技巧的朋友需要谨慎操作哦 xff0c 如有疑问可以微信留言给我们 下
  • Android终端通过adb 配置静态IP和DNS

    有时我们需要使用命令行来配置eth0的IP信息 xff0c 这在linux系统是非常简单的 xff0c 网上也有很多资料 但是在Android系统 xff0c 就非常困难 xff0c 因为Android精简掉了很多linux命令 xff0c
  • 【官方】下载最新adb及安装驱动的方法

    Only adb 驱动 xff1a https adbdriver com downloads adb工具 xff1a https adbshell com upload adb zip https adbshell com downloa
  • 中芯微随身WIFI破解实体SIM卡槽(不拆机,无需切卡密码)

    目前网上卖的一些随身WIFI是中芯微的方案 MF782 部分产品限制用户使用实体SIM卡 只能使用内置eSIM 下面谈谈解决方案 1 中沃的没有限制 实体SIM卡优先 检测到插的有实体SIM卡 就使用实体SIM卡网络 2 另外一部分网上提供
  • 高通Android随身WIFI屏蔽商家远程控制断网

    nbsp nbsp nbsp nbsp 部分随身WIFI商家后台会监测用户是否使用的是自家的eSIM 若使用了外置卡槽或eSIM的ICCID改变就会断网 主要表现是先联网后突然变成飞行模式 或联网后开热点变飞行模式 这就是商家后台做了监测
  • Linux kernel make clean时忽略部分文件(不被删除)

    有时我们在运行make clean 时 xff0c 需要保留某些 o 文件 xff0c 这就需要我们修改 Makefile 文件 xff0c 下面以 linux 2 6 18 的 Makefile 为例 xff1a Files to ign
  • Audio参数讲解

    一 音频基础参数 frame bits 一帧数据的位数比如 xff1a 16bits 2ch frame bits 61 16 2 sample bits 采样位数 比如16bit 24bit 32bit period size 指一个周期
  • linux ALSA 驱动架构

    一 kernel Audio驱动架构主流有两大类 xff0c 一类是SOC Machine架构 xff0c 另一类是simple card架构 MTK QCom主要采用machine架构 xff0c rockchip采用simple car
  • adaboost提升算法

    引言 俗话说得好 xff0c 三个臭皮匠赛过诸葛亮 更主要的是三个臭皮匠好找 xff0c 一个诸葛亮太难找了 在机器学习里面也是一样的 我们可以设计出各种分类器 xff0c 然而分类器的效果确实不一而同的 xff0c 相对而言 xff0c
  • 长虹电视刷机固件包汇总

    为了解决部分朋友因应用引起的电视死机 无法开机 系统被破坏等情形 xff0c 快客服务特开此帖为朋友们提供刷机方法 xff0c 但刷机有风险 xff0c 如完全不懂刷机技巧的朋友需要谨慎操作 xff0c 用户自行刷机所产生问题自行负责 xf
  • WebRTC-集成qsv硬解码实现

    1 Window下QSV硬解码配置 在libavcodec codec list c下添加 amp ff h264 qsv decoder 在ffmpeg generate gni下加入 34 libavcodec h264idct c 3
  • ijkplayer-添加播放截图功能

    应用播放的时候需要截图 xff0c 可以在上层使用TexturView来使用截图 xff0c 不过太具有局限性呢 xff0c 还是在底层处理比较好 那么先分析下可以在哪里加截图呢 xff1f 看到网上很多做的都不能支持硬解截图 xff0c
  • avformat_seek_file及其flag含义

    我们从ijk中seek的处理流程来看ffmpeg的这个问题 int ffp seek to l FFPlayer ffp long msec assert ffp VideoState is 61 ffp gt is int64 t sta
  • 单例模式

    单例模式 xff1a include lt iostream gt using namespace std class Singleton public Singleton cout lt lt 34 Singleton虚构函数 34 lt
  • ffmpeg系列-解决ffmpeg获取aac音频文件duration不准

    这个问题是这样产生的 xff0c 一同事反应会随机出现ijk获取到的aac文件的duration不准 xff0c 发来一看 xff0c 确实不准 xff0c 在AE或者系统mediaplayer中得到的都是8 4秒 xff08 准确时间是M
  • 基于librtmp的推流实现

    1 推流 配置好rtmpdump库后 xff0c 我们可以先用命令行来推流看下效果 2 流程图 使用librtmp发布RTMP流的可以使用两种API xff1a RTMP SendPacket 和RTMP Write 使用RTMP Send
  • ijkplayer-音视频变速播放实现

    本文主要分析变速播放框架实现细节 xff0c 不分析sonic以及soundtouch变速算法 在我的sonic变速变调原理一文中会详细讲解基于基音周期来实现变速变调的原理 1 变速入口分析 从jni层的 setPropertyFloat函
  • 提升树,bagging与随机森林

    提升树是一种以分类树或者回归树为基本分类器的提升方法 对于分类树只需将adaboost算法中的基函数设置为二分类二叉树即可 而回归树则是根据残差来训练下一个分类器的回归二叉树 下面主要介绍一下回归提升树的算法 回归提升树 回忆一下 xff0
  • Android_WakeLock使用

    1 前言与WakeLock简介 1 1 前言 一些手机app xff08 如微信 QQ等 xff09 有新消息来到达 xff0c 手机屏幕即使在锁屏状态下也会亮起 xff0c 并提示用户有新消息 但是 xff0c 一般情况下手机锁屏后 xf
  • ContentResolver.query详解

    1 查询手机的联系人 public void getContacts ContentResolver contentResolver 61 this getContentResolver Cursor cursor 61 contentRe

随机推荐

  • jni开发-GetMethodID与CallObjectMethod的坑

    在java层中声明一个方法用于创建一个audiotrack xff0c 在C层中调用这个方法并获取audiotrack对象 先看下面的代码 xff1a SuPlayer java public AudioTrack createAudioT
  • docker启动rabbitMQ访问不了管理界面-问题解决

    rabbitMQ可以在docker上面去安装启动 xff0c 这样快捷方便 xff0c 也利于本地开发的调试 先在docker下去拉取docker docker pull rabbitmq 这样拉取了rabbitMQ最新的版本后 xff0c
  • Royal TSX 从入门到高效使用

    Royal TSX 是一款 macOS 下可用的远程连接软件 xff0c 类似于 Windows 系统的 XShell 免费版最多支持 10 个连接 xff0c 对于个人开发而言 xff0c 已经足够了 目录 引言 一 下载安装 二 基础配
  • PIP升级错误解决方法

    pip span class token function install span upgrade pip 执行后报如下错误 Looking span class token keyword in span indexes https p
  • 使用自定义菜单等接口类功能出现“SSL connect error”的错误原因及解决方案

    这种情况很少出现 xff0c 但是出现了很难排查 xff0c 因为环境检测结果就是curl openssl都开启了 xff0c 为什么还是不行呢 xff1f 通过技术人员耐心的排查发现是CURL中SSL的版本太低 xff0c 不支持CURL
  • 删除数组中的某个数字

    span class hljs comment 这个程序是今天多益网络的编程题 xff0c 很简单的删除一个数组中值为2的元素 span span class hljs comment 看着很简单 xff0c 但是我没有做出来 xff0c
  • 强化学习和控制

    马尔科夫决策过程MDP值迭代和政策迭代 值迭代政策迭代比较 MDP模型无限状态的MDPs 离散化值函数估计 使用一个模型或模拟器适应值迭代 在强化学习中 xff0c 我们将提供一个奖赏函数 xff0c 当目标完成的好时 xff0c 便奖赏
  • Centos7——防火墙(Firewall)开启常见端口命令

    Centos7 默认安装了 firewalld xff0c 如果没有安装的话 xff0c 则需要YUM命令安装 xff1b firewalld真的用不习惯 xff0c 与之前的iptable防火墙区别太大 安装Firewall命令 xff1
  • FTP服务器下载视频,自定义保存路径

    FTP服务器下载视频 xff0c 自定义保存路径 controller层方法 当前使用 xff0c 浏览器自动弹框 Description 从FTP服务器下载文件 64 param host FTP服务器hostname 64 param
  • OEPNCV_摄像头采集显示

    span class token macro property span class token directive keyword include span span class token string lt stdio h gt sp
  • ArchLinux系统安装(BIOS)

    一 简介 Arch linux 是朝向轻量 xff08 lightweight xff09 以及简单 xff08 simple xff09 的 Linux 发行版 其中 简单 xff08 Simplicity xff09 被定义为 避免不必
  • Android 常见的抓log方法总结

    1 kernel log 1 adb shell dmesg gt c log dmesg txt 2 adb shell cat proc kmsg gt c log kmsg 3 findstr xx 只看xx相关的log 4 查看特定
  • 工作纪实_24-使用@Sl4j注解但是确无法使用log.info打印日志

    如果出现这种情况 xff0c 第一时间先执行打包mvn clean package命令 xff0c 这么做是为了检查log日志包是否齐全 xff0c 此次我打包报错是找不到org slf4j包 xff0c 很明显 xff0c 我们检查一下相
  • gradle-wrapper.properties中各属性的含义

    gradle wrapper properties中各属性的含义 1 gradle wrapper properties 每一个用gradle编译的工程 xff0c 都会有一个gradle wrapper目录 该目录下有2个文件 xff1a
  • cordova 打包步骤

    年底了 xff0c 好多资料都在整理 xff0c 为了避免遗忘 xff0c 也为了利益他人吧 直接上步骤吧 xff1a 增加运行环境的模板 cordova platform add android 编译android的程序 cordova
  • 视图绑定

    视图的绑定从另一个角度看就是implicit的转换 主要用在两个场合 1 当一个T类型的变量t要装换成A类型时 2 当一个类型T的变量t无法拥有A类型的a方法或变量时 其实视图的绑定是为了更方便的使用隐式装换 如果我们不用视图绑定看看 这个
  • 【Settings随记:二】一级菜单,二级菜单的添加与隐藏,添加辅助功能

    我们可以先从Settings的启动来看 先进入到AndroidManifest xml 找到启动的Activity span class token tag span class token tag span class token pun
  • 新加装的硬盘,装上系统后发现EFI分区没有被创建,还是用旧硬盘的EFI分区

    引发问题 xff1a 如果没有旧硬盘就没法引导系统 xff0c 没法开机 解决办法 xff1a 在新硬盘增加一个EFI分区 目前情况大概就是这个样子 xff1a xff08 本人忘了截图 xff0c 用别人的 xff09 可见 xff0c
  • 信息安全重点知识

    一 信息安全概述 网络空间安全的重要性 xff1a 没有网络安全就没有国家安全信息安全 xff1a 防止数据未授权的访问 xff0c 数据有意和物一的威胁 网络安全是信息安全的子集 信息安全的三要素 xff08 CIA xff09 xff1
  • 线程同步的四种方式

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