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

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

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

全栈程序员社区此处内容已经被作者隐藏,请输入验证码查看内容
验证码:
请关注本站微信公众号,回复“验证码”,获取验证码。在微信里搜索“全栈程序员社区”或者“www_javaforall_cn”或者微信扫描右侧二维码都可以关注本站微信公众号。

  用户模式下的线程同步机制提供了非常好的性能,但他们也的确存在一些局限性,而且不适用于许多应用程序,例如,对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. 线程同步对象速查表

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

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

(0)
全栈程序员-站长的头像全栈程序员-站长


相关推荐

  • mybatis返回map集合_java遍历map的key和value

    mybatis返回map集合_java遍历map的key和value匿名用户1级2018-06-10回答一、概述MyBatis中在查询进行select映射的时候,返回类型可以用resultType,也可以用resultMap,resultType是直接表示返回类型的,而resultMap则是对外部ResultMap的引用,但是resultType跟resultMap不能同时存在。在MyBatis进行查询映射时,其实查询出来的每一个属性都是放在一个对应的Map里面…

    2022年10月5日
    2
  • eclipse创建一个java项目目录_Eclipse创建JAVA项目

    eclipse创建一个java项目目录_Eclipse创建JAVA项目项目:project包:package类:class为了便于硬盘上的文件进行管理,通常都会将文件分目录进行存放。同理,在程序开发中,也需要将编写的类在项目中分目录存放,以便于文件管理。为此,Jaca引入了包(package)机制,(貌似跟Python的包差不多),程序可以通过声明包的方式对Java类定义目录。Java中的包是专门用来存放类的,通常功能相同的类存放在相同的包中。在声明包时,使用Pac…

    2022年7月19日
    16
  • 【Custom Mutator Fuzz】Libprotobuf + LibFuzzer联合使用

    【Custom Mutator Fuzz】Libprotobuf + LibFuzzer联合使用终于到了与fuzzer结合使用的章节了,本篇文章为Libprotobufmutatorfuzzinglearning项目的第二个练习,其中有一些坑点,在本文中也进行了标注编写不易,如果能够帮助到你,希望能够点赞收藏加关注哦Thanks♪(・ω・)ノPS:文章末尾有联系方式,交个朋友吧~本文链接:模糊测试系列往期回顾:【CustomMutatorFuzz】简单Protobuf使用练习【CustomMutatorFuzz】ProtocolBuffer基础(下):C++生成代.

    2022年9月13日
    4
  • ReadProcessMemory函数的分析「建议收藏」

    ReadProcessMemory函数的分析「建议收藏」ReadProcessMemory函数用于读取其他进程的数据。我们知道自远古时代结束后,user模式下的进程都有自己的地址空间,进程与进程间互不干扰,这叫私有财产神圣不可侵犯。但windows里还真就提供了那么一个机制,让你可以合法的获取别人的私有财产,这就是ReadProcessMemory和WriteProcessMemory。为什么一个进程居然可以访问另一个进程的地址空间呢?因为独立的只是低

    2022年10月4日
    2
  • java pdf 转 word_PDF怎么转换成Word,免费,完整的那种

    java pdf 转 word_PDF怎么转换成Word,免费,完整的那种简介PDF可以分为文字型PDF和图片型PDF,文字型PDF即可以选中文字内容的PDF,反之图片型PDF即无法选中文字的PDF,其内容实际上是图片。本文针对不同类型,介绍PDF转Word方法,可以说是目前的最优解,没有之一。文字型PDF转Word方法1-直接用Word打开优点简单方便缺点部分样式丢失,排版错位,转换并不完美部分文件会有乱码无法识别图片型PDF里的文字总结适合对样式不敏感,主要关心正文…

    2022年4月30日
    55
  • mysql数据类型有哪几种_数据库 数据类型

    mysql数据类型有哪几种_数据库 数据类型Mysql支持的多种数据类型主要有:数值数据类型、日期/时间类型、字符串类型。整数浮点数&定点数注:定点数以字符串形式存储,对精度要求高时使用decimal较好;尽量避免对浮点数进行减法和比较运算。时间/日期类型字符串类型blog-二进制大对象,用来存储可变数量的数据。…

    2022年9月20日
    2

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

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