首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往

在主程序退出期间销毁等待std::conditional_variable的线程的正确方法

是使用std::condition_variable的成员函数notify_all()来通知等待的线程退出。具体步骤如下:

  1. 在主程序退出前,创建一个std::condition_variable对象和一个std::mutex对象,用于线程间的同步和通信。
  2. 在等待std::condition_variable的线程中,使用std::unique_lock<std::mutex>对象锁住std::mutex,并调用std::condition_variable的成员函数wait()等待条件满足。
  3. 在主程序退出前,调用std::condition_variable的成员函数notify_all()来通知所有等待的线程退出。
  4. 在等待std::condition_variable的线程中,当收到通知后,检查条件是否满足,如果不满足则继续等待,如果满足则退出线程。

下面是一个示例代码:

代码语言:cpp
复制
#include <iostream>
#include <thread>
#include <condition_variable>

std::condition_variable cv;
std::mutex mtx;
bool condition = false;

void worker_thread()
{
    std::unique_lock<std::mutex> lock(mtx);
    cv.wait(lock, []{ return condition; });
    // 执行线程任务
    std::cout << "Worker thread exiting..." << std::endl;
}

int main()
{
    std::thread t(worker_thread);

    // 模拟主程序执行
    std::this_thread::sleep_for(std::chrono::seconds(2));

    // 设置条件为true,并通知等待的线程
    {
        std::lock_guard<std::mutex> lock(mtx);
        condition = true;
    }
    cv.notify_all();

    // 等待线程退出
    t.join();

    std::cout << "Main program exiting..." << std::endl;

    return 0;
}

在这个示例中,worker_thread()函数是等待std::condition_variable的线程,它会在条件满足时退出。主程序中,通过设置条件为true,并调用cv.notify_all()来通知等待的线程退出。最后,主程序等待线程退出后退出。

这种方法可以确保在主程序退出期间,等待std::condition_variable的线程能够正确退出,避免线程泄漏和资源浪费。

腾讯云相关产品和产品介绍链接地址:

页面内容是否对你有帮助?
有帮助
没帮助

相关·内容

谈谈单例模式

那么有人要问,那我不就定义一个类,程序只初始化一个全局的实例就好了吗?没错,这样是可以的。但是我们都知道程序会经过多人的接手维护和开发,比如第N个接手程序的时候,并不知道这个类定义的时候只能初始化一个实例,然后又实例化了新的对象, 则可能会造成意想不到的场景。那么这时候就要提到防御性编程,个人认为单例模式的实现也是防御性编程的一种方式,让这个类保证只有一个实例化对象,并且如果试图构造多个对象的时候,在程序的编译期报错。题外话,这也是为什么本人在进行一些稍大规模开发的时候,只会去选择强类型语言,而不会选择弱类型语言的原因,强类型语言会在编译期间帮我们避免很多运行时可能产生的的Bug。

03

CreateMutex、WaitForSingleObject、ReleaseMutex——创建互斥对象

CreateMutex CreateMutex作用是找出当前系统是否已经存在指定进程的实例。如果没有则创建一个互斥体。 互斥对象是系统内核维护的一种数据结构,它保证了对象对单个线程的访问权 互斥对象的结构:包含了一个使用数量,一个线程ID,一个计数器 使用数量是指有多少个线程在调用该对象,线程ID是指互斥对象维护的线程的ID 计数器表示当前线程调用该对象的次数 声明 HANDLE CreateMutex( LPSECURITY_ATTRIBUTESlpMutexAttributes, // 指向安全属性的指针 BOOLbInitialOwner, // 初始化互斥对象的所有者 LPCTSTRlpName // 指向互斥对象名的指针 ); 说明 创建一个互斥体(MUTEX) 返回值 Long,如执行成功,就返回互斥体对象的句柄;零表示出错。会设置GetLastError。即使返回的是一个有效句柄,但倘若指定的名字已经存在,GetLastError也会设为ERROR_ALREADY_EXISTS 参数表 参数 类型及说明lpMutexAttributes SECURITY_ATTRIBUTES,指定一个SECURITY_ATTRIBUTES结构,或传递零值(将参数声明为ByVal As Long,并传递零值),表示使用不允许继承的默认描述符 bInitialOwner Long,如创建进程希望立即拥有互斥体,则设为TRUE。一个互斥体同时只能由一个线程拥有 lpName String,指定互斥体对象的名字。用vbNullString创建一个未命名的互斥体对象。如已经存在拥有这个名字的一个事件,则打开现有的已命名互斥体。这个名字可能不与现有的事件、信号机、可等待计时器或文件映射相符它的具体作用是每调用它一次将互斥对象的计数器减一,直到减到零为止,此时释放互斥对象,并将互斥对象中的线程id 置零。 它的使用条件是,互斥对象在哪个线程中被创建,就在哪个线程里面释放。因为调用的时候会检查当前线程的id是不是与互斥对象中保存的id一致,若一致,则此次操作有效,不一致,则无效。 注解编辑 一旦不再需要,注意必须用CloseHandle函数将互斥体句柄关闭。从属于它的所有句柄都被关闭后,就会删除对象线程中止前,一定要调用ReleaseMutex释放互斥体,如不慎未采取这个措施,就会将这个互斥体标记为废弃(下一个释放的等待函数会返回WAIT_ABANDONED),并自动释放所有权。共享这个互斥体的其他应用程序也许仍 然能够用它,但会接收到一个废弃状态信息,指出上一个所有进程未能正常关闭。这种状况是否会造成影响取决于涉及到的具体应用程序。在Windows系统中,线程可以在等待函数中指定一个此线程已经拥有的互斥体,由于Windows的防死锁机制,这种做法不会阻止此线程的运行。 使用例子编辑 常用操作mutex的函数还有:ReleaseMutex/OpenMutex/WaitForSingleObject/WaitForMultipleObjects。 创建互斥体 h_mutex1=CreateMutex(NULL,FALSE,”mutex_for_readcount”);//创建一个互斥体 检查错误代码 #include <stdio.h> #include <windows.h> …… // main function HANDLE m_hMutex = CreateMutex(NULL, FALSE, “Sample07”);// 检查错误代码 if (GetLastError() == ERROR_ALREADY_EXISTS) { // 如果已有互斥量存在则释放句柄并复位互斥量 CloseHandle(m_hMutex); m_hMutex = NULL; // 程序退出 return FALSE; };//上面这段代码演示了有名互斥量在进程互斥中的用法。代码的核心是CreateMutex()对有名互斥量的创建。CreateMutex() 用于有独占要求的程序 (在其进程运行期间不允许其他使用此端口设备的程序运行,或不允许同名程序运行)。 详细例子 下面这段代码详细介绍了CreateMutex函数的使用方法: #include “stdafx.h”#include “windows.h”int main(int argc, char* argv[]){ HANDLE m_hMutex = CreateMutex(NULL,TRUE,”cplusplus_me”); DWORD dwRet = GetLastError(); if (m_hMutex) { if (ERROR_ALREADY_EXISTS == dwRe

01

c#之task与thread区别及其使用

1.什么是thread 当我们提及多线程的时候会想到thread和threadpool,这都是异步操作,threadpool其实就是thread的集合,具有很多优势,不过在任务多的时候全局队列会存在竞争而消耗资源。thread默认为前台线程,主程序必须等线程跑完才会关闭,而threadpool相反。 总结:threadpool确实比thread性能优,但是两者都没有很好的api区控制,如果线程执行无响应就只能等待结束,从而诞生了task任务。 2.什么是task task简单地看就是任务,那和thread有什么区别呢?Task的背后的实现也是使用了线程池线程,但它的性能优于ThreadPoll,因为它使用的不是线程池的全局队列,而是使用的本地队列,使线程之间的资源竞争减少。同时Task提供了丰富的API来管理线程、控制。但是相对前面的两种耗内存,Task依赖于CPU对于多核的CPU性能远超前两者,单核的CPU三者的性能没什么差别。

02
领券