C++之内核对象进行线程同步

用户模式下的线程同步机制提供了非常好的性能,但他们也的确存在一些局限性,而且不适用于许多应用程序,例如,对Interlocked系列函数只能对一个值进行操作,它们从来不会把线程切换到等待状态。我们可以

大家好,又见面了,我是全栈君,今天给大家准备了Idea注册码。

C++之内核对象进行线程同步此处内容已经被作者隐藏,请输入验证码查看内容
验证码:
请关注本站微信公众号,回复“”,获取验证码。在微信里搜索“”或者“”或者微信扫描右侧二维码都可以关注本站微信公众号。

  用户模式下的线程同步机制提供了非常好的性能,但他们也的确存在一些局限性,而且不适用于许多应用程序,例如,对Interlocked系列函数只能对一个值进行操作,它们从来不会把线程切换到等待状态。我们可以用关键段把线程切换到等待状态,但是他们只能用来对同一个进程中的线程进行同步,。此外,在使用关键段的时候我们很容易陷入死锁的情形,因为我们无法为进入关键段指定一个很长等待时间。接下来本文将对使用内核对象进行线程同步的相关知识进行总结。

1. 等待函数

  等待函数使一个线程自愿进入等待状态,直到指定的内核对象被触发为止。Windows提供了WaitForSingleObject和WaitForMultipleObjects两个等待函数。

1.1 WaitForSingleObject

  (1)函数格式

    DWORD WaitForSingleObject(

      HANDLE hObject,

      DWORD dwMilliseconds);

    :第二个参数为等待时间,单位毫秒,INFINITE被定义为0xFFFFFFFF  

  (2)示例

DWORD ret = WaitForSingleObject(hProcess, 5000)
switch (ret)
{
case WAIT_OBJECT_0:
    // Thew process terminated
    break;
case WAIT_TIMEOUT:
    // The process did not terminated within 5000 milliseconds
    break;
case WAIT_FAILED:
    // Bad call to function(invalid handle?)
    break;
}

1.2 WaitForMultipleObjects

  (1)函数格式

    DWORD WaitForMultipleObjects(
       DWORD dwCount,  // 等待内核对象数量
       CONST HANDLE* phObjects, // 等待内核对象句柄集合
       BOOL bWaitAll,   // 判断是否等待所有内核对象触发
       DWORD dwMilliseconds); // 等待时间

  (2)示例

HANDLE phObjects[3];
phObjects[0] = hObject1;
phObjects[1] = hObject1;
phObjects[2] = hObject1;
DWORD ret = WaitForMultipleObjects(sizeof(phObjects)/sizeof(phObjects[0]), phObjects, false, 5000);
switch (ret)
{
case WAIT_TIMEOUT:
    // None of objects became signaled within 5000 milliseconds
    break;
case WAIT_FAILED:
    // Bad call to function(invalid handle?)
    break;
case WAIT_OBJECT_0 + 0;
    break;
case WAIT_OBJECT_0 + 1;
    break;
case WAIT_OBJECT_0 + 2;
    break;
}

2. 事件内核对象

2.1 成员函数

  (1)CreateEvent

    DWORD CreateEvent(
      PSECURITY_ATTRIBUTES psa,
      BOOL bManualReset, // 手动为TRUE,自动为FALSE
      BOOL bInitialState, // TRUE为触发,FALSE为未触发
      PCTSTR pszName
      );

  (2)OpenEvent

    HANDLE OpenEvent(
      DWORD dwDesiredAccess,
      BOOL bInherit,
      PCTSTR pszName)

  (3)SetEvent

     BOOL SetEvent(Handle hEvent)

  (4)ResetEvent

     BOOL ResetEvent(HANDLE hEvent)

2.2 重点说明

  (1)事件的触发表示一个操作已经完成,有两种类型的事件对象:手动重置事件和自动重置事件。当一个手动重置事件被触发的时候,正在等待该事件的所有线程都变成可调度状态。而当一个自动重置事件被触发的时候,只有一个正在等待该事件的线程会变成可调度状态。

  (2)其他进程中的线程访问事件对象的方法:CreateEvent、继承、DuplicateHandle或OpenEvent

  (3)对自动重置对象来说,通常不需要调用ResetEvent,这是因为系统会自动将事件重置,相反Microsoft并没有为手动重置对象定义一个等待成功所引起的副作用。

4. 可等待的计时器内核对象

5. 信号量内核对象

6. 互斥量内核对象

  互斥量(mutex)内核对象用来确保一个线程独占对一个资源的访问,互斥量对象包含一个使用计数、线程ID以及一个递归计数。

6.1 成员函数

  (1)CreateMutex

    HANDLE CreateMutex(
        PSECURITY_ATTRIBUTES psa,
        BOOL bInitialOwner, // FALSE表示不为任何线程占用
        PCTSTR pszName );

  (2)OpenMutex

      HANDLE OpenMutex(
         DWORD dwDesiredAccess,
         BOOL bInHeritHandle,
         PCTSTR pszName);

  (3)ReleaseMutex

      BOOL ReleaseMutex(HANDLE hMutex);

6.2 循环数组实现线程安全的消息队列

C++之内核对象进行线程同步
C++之内核对象进行线程同步

#include "stdio.h"
#include <Windows.h>
#include <iostream>
using namespace std;
// 数组实现循环消息队列
#define ARRAY_SIZE 8

template<typename T>
class CircleQueue
{
public:
    CircleQueue();
    ~CircleQueue();

    void PushMsg(T msg);
    T PopMsg();

    bool IsFull();
    bool IsEmpty();
    int GetLength();

    void PrintCircleQueue();

private:
    T *m_pArray;
    int m_nArraySize;
    int m_nHead;
    int m_nTail;
    HANDLE m_hMutex;
};

template<typename T>
CircleQueue<T>::CircleQueue():m_nHead(0),m_nTail(0),m_nArraySize(ARRAY_SIZE)
{
    m_hMutex = CreateMutex(NULL, false, NULL);
    m_pArray = new T[m_nArraySize];
}

template<typename T>
CircleQueue<T>::~CircleQueue()
{
    delete[] m_pArray;
    m_pArray = NULL;
    CloseHandle(m_hMutex);
}

template<typename T>
int CircleQueue<T>::GetLength()
{
    return (m_nTail-m_nHead+m_nArraySize)%m_nArraySize;    
}

template<typename T>
bool CircleQueue<T>::IsEmpty()
{
    if (m_nTail == m_nHead)
    {
        return true;
    }
    return false;
}

template<typename T>
bool CircleQueue<T>::IsFull()
{
    if ((m_nTail + 1) % m_nArraySize == m_nHead)
    {
        return true;
    }

    return false;
}

template<typename T>
T CircleQueue<T>::PopMsg()
{
    T msg = static_cast<T>(NULL);
    if (!IsEmpty())
    {
        DWORD nRet = WaitForSingleObject(m_hMutex, 5000);
        switch (nRet)
        {
        case WAIT_OBJECT_0:
            {
                msg = m_pArray[m_nHead];
                cout << "从消息队列取出消息:" << msg << endl;
                m_nHead = (m_nHead+1) % m_nArraySize;
            }
            break;
        case WAIT_TIMEOUT:
            {
                cout << "Wait TimeOut!" << endl;
            }
            break;
        case WAIT_FAILED:
            {
                cout << "Wait FAILED" << endl;
            }
            break;
        }
        ReleaseMutex(m_hMutex);
    }
    else
    {
        cout << "消息队列为空!" << endl;
    }
    return msg;
}

template<typename T>
void CircleQueue<T>::PushMsg( T msg )
{
    if (!IsFull())
    {
        DWORD nRet = WaitForSingleObject(m_hMutex, 5000);
        switch (nRet)
        {
        case WAIT_OBJECT_0:
            {
                m_pArray[m_nTail] = msg;
                cout << "添加消息到消息队列:" << msg << endl;
                m_nTail = (m_nTail+1) % m_nArraySize;
            }
            break;
        case WAIT_TIMEOUT:
            {
                cout << "Wait TimeOut!" << endl;
            }
            break;
        case WAIT_FAILED:
            {
                cout << "Wait FAILED" << endl;
            }
            break;
        }
        ReleaseMutex(m_hMutex);
    }
    else
    { 
        cout << "消息队列已满,请等待..."<<endl;
    }
}

template<typename T>
void CircleQueue<T>::PrintCircleQueue()
{
    int nStart = m_nHead;
    int nEnd = m_nTail;
    while(nStart!= nEnd)
    {
        cout << m_pArray[nStart];
        nStart = (nStart+1) % m_nArraySize;
    }
    cout << endl;
}
int main()
{
    CircleQueue<int> *pQueue1 = new CircleQueue<int>;
    CircleQueue<char *> *pQueue2 = new CircleQueue<char *>;
    cout << "消息队列1:" << endl;
    pQueue1->PushMsg(1);
    pQueue1->PushMsg(2);
    pQueue1->PushMsg(3);
    pQueue1->PushMsg(4);
    pQueue1->PopMsg();
    pQueue1->PushMsg(5);
    pQueue1->PushMsg(6);
    pQueue1->PopMsg();
    pQueue1->PushMsg(7);
    pQueue1->PopMsg();
    pQueue1->PushMsg(8);
    pQueue1->PrintCircleQueue();

    cout << "消息队列2:" << endl;
    pQueue2->PushMsg("hello");
    pQueue2->PushMsg("world");
    pQueue2->PushMsg("I");
    pQueue2->PushMsg("am");
    pQueue2->PushMsg("coming");
    pQueue2->PopMsg();
    pQueue2->PrintCircleQueue();
    return 0;
}

View Code

C++之内核对象进行线程同步

7. 线程同步对象速查表

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/120148.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • redflag linux安装教程,硬盘安装REDFlag LINUX体会

    redflag linux安装教程,硬盘安装REDFlag LINUX体会我是一名LINUX的初学者,在看了许多LINUX的介绍之后,在本着大胆和心细的原则下,尝试了一回安装LINUX。现把我的一些心得和体会和大家分享,希望对一些入门级的朋友有所帮助。我装的是REDFlagLINUX,我原来的操作系统是WINXP,本着学习LINUX的和省钱至上的想法,我选择了安装WINXP和LINUX的双系统,我在网上下载了LINUX的ISO文件,先保存在随意的一个硬盘里,只要不是…

  • 毕业——少年,你还太弱,请专心练剑

    有段时间没有更新博客,一是比较忙,二是考虑自己的博客内容。之前的博客都是自己的学习记录,输入的同时做了输出,自己思考了一下主要就是以下几类:1、一些比较常见的知识点,像这些都是本来就已经存在的内容,我只是做了一次梳理按照我的逻辑整理出来,就算我不整理,也能找的到,所以我觉得存在的必要性并不大。2、错误记录,自己学习和开发过程中遇到的各种问题,对于遇到类似问题的同学可能有所帮助。3、自己的经验总结,这

  • C语言中的移位运算

    C语言中的移位运算移位运算移位运算包括左移和右移左移运算:x&amp;lt;&amp;lt;k:x左移k位,并在右端补零。右移运算:逻辑右移:x&amp;gt;&amp;gt;k:x右移k位,并在左端补零。算术右移:x&amp;gt;&amp;gt;k:x右移k位,并在左端补最高有效位的值。下表为对一个8位参数x的两个不同的值做不同的一位操作得到的结果:操作值参数x[01100011][10010101]x&amp;l

  • android studio 导入eclipse乱码解决「建议收藏」

    android studio 导入eclipse乱码解决「建议收藏」在开发过程中遇到androidstudio导入eclipse乱码,综合网上查找的答案,我是这样解决的:1、首先在module的bulid.gradle文件的android标签中加入以下内容:applyplugin:’com.android.xxxx’android{compileSdkVersion21buildToolsVersion”21.

  • [文字雲產生器] Tagxedo 把文字串成雲、變成畫,印在 T-Shirt、馬克杯、詩袋…….

    [文字雲產生器] Tagxedo 把文字串成雲、變成畫,印在 T-Shirt、馬克杯、詩袋…….http://www.tagxedo.com/app.html有種東西叫「WordClouds」,就是把一堆文字依照不同的大小、顏色、角度與位置拼湊在一起,讓他變成像一朵雲一般、組合成各種不同的形狀。平常最成看到類似的創作應該是在T-Shirt或馬克杯上,用各種樣式組成不同形狀的文字雲,把想呈現的文字、地名或專有名詞寫在衣服上,看起來相當帥氣!如果你不是設計師卻想玩玩看Wor…

    2022年10月30日
  • golang永久激活_在线激活

    (golang永久激活)JetBrains旗下有多款编译器工具(如:IntelliJ、WebStorm、PyCharm等)在各编程领域几乎都占据了垄断地位。建立在开源IntelliJ平台之上,过去15年以来,JetBrains一直在不断发展和完善这个平台。这个平台可以针对您的开发工作流进行微调并且能够提供…

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号