方法阻塞的解决方案之一

1、简单使用

一个h一个cpp文件 

#pragma once
#include <iostream>
#include <thread>
#include <atomic>
#include <chrono>
#include <string>class Person {public:struct dog {std::string name;int age;};public:void a(std::atomic<bool>& running, int param1, double param2, const std::string& param3);void startA(int param1, double param2, const std::string& param3);
};

#include <iostream>
#include <thread>
#include <atomic>
#include <chrono>
#include <string>
#include "osg.h"void Person::a(std::atomic<bool>& running, int param1, double param2, const std::string& param3) {std::cout << "Function a started with params " << param1 << ", " << param2 << ", " << param3 << "." << std::endl;// 模拟耗时操作while (running) {// 执行一些操作}std::cout << "Function a ended." << std::endl;
}void Person::startA(int param1, double param2, const std::string& param3) {std::atomic<bool> running(true);// 创建并启动线程std::thread thread_a(&Person::a, this, std::ref(running), param1, param2, param3);std::this_thread::sleep_for(std::chrono::seconds(10));if (running.load()) {std::cout << "stop" << std::endl;running = false;}// 等待线程完成执行if (thread_a.joinable()) {thread_a.join();}
}int main() {Person person;person.startA(42, 3.14, "Hello");// ... 其他代码 ...return 0;}

2、方法A中存在引用

错误示例:

将sum执行的数据保存下来

#include <iostream>
#include <thread>
#include <atomic>
#include <chrono>
#include <string>
#include "osg.h"void Person::a(std::atomic<bool>& running, int& sum, double param2) {std::cout << "Function a started with params " << sum << ", " << param2 << std::endl;// 模拟耗时操作while (running) {// 执行一些操作for (int i = 0; i < 10000000; i++) {sum = i;}}std::cout << "Function a ended." << std::endl;
}void Person::startA(int param1, double param2, const std::string& param3) {for (int i = 0; i < 2; i++) {int sum = 0;std::atomic<bool> running(true);// 创建并启动线程std::thread thread_a(&Person::a, this, std::ref(running), sum, param2);std::this_thread::sleep_for(std::chrono::seconds(5));if (running.load()) {std::cout << "stop" << std::endl;running = false;}// 等待线程完成执行if (thread_a.joinable()) {thread_a.join();std::cout << "等待线程完成执行" << std::endl;}std::cout << "sum: " <<sum<< std::endl;}std::cout << "任务结束" << std::endl;}
int main() {Person person;person.startA(42, 3.14, "Hello");// ... 其他代码 ...return 0;
}

编译都过不去

正确示例:

 只修改一句

        std::thread thread_a(&Person::a, this, std::ref(running), std::ref(sum), param2);
#include <iostream>
#include <thread>
#include <atomic>
#include <chrono>
#include <string>
#include "osg.h"void Person::a(std::atomic<bool>& running, int& sum, double param2) {std::cout << "Function a started with params " << sum << ", " << param2 << std::endl;// 模拟耗时操作while (running) {// 执行一些操作for (int i = 0; i < 1000000000; i++) {sum = i;}}std::cout << "Function a ended." << std::endl;
}void Person::startA(int param1, double param2, const std::string& param3) {for (int i = 0; i < 2; i++) {int sum = 0;std::atomic<bool> running(true);// 创建并启动线程std::thread thread_a(&Person::a, this, std::ref(running), std::ref(sum), param2);std::this_thread::sleep_for(std::chrono::seconds(5));if (running.load()) {std::cout << "stop" << std::endl;running = false;}// 等待线程完成执行if (thread_a.joinable()) {thread_a.join();std::cout << "等待线程完成执行" << std::endl;}std::cout << "sum: " <<sum<< std::endl;}std::cout << "任务结束" << std::endl;}
int main() {Person person;person.startA(42, 3.14, "Hello");// ... 其他代码 ...return 0;
}

3、A方法阻塞时间过长,希望停止

如果Person::a 方法卡住了,那么 if (thread_a.joinable()) { thread_a.join(); } 就阻塞了,std::cout << "sum: " <<sum<< std::endl; 值就得不到了,除非a方法完成了

#include <iostream>
#include <thread>
#include <atomic>
#include <chrono>
#include <string>
#include "osg.h"void Person::a(std::atomic<bool>& running, int& sum, const double &param2) {std::cout << "Function a started with params " << sum << ", " << param2 << std::endl;// 模拟耗时操作for (int i = 0; i < 10; i++) {std::this_thread::sleep_for(std::chrono::seconds(1));sum = i;}std::cout << "Function a ended." << std::endl;}void Person::startA(int param1, double param2, const std::string& param3) {for (int i = 0; i < 2; i++) {int sum = 0;std::atomic<bool> running(true);// 创建并启动线程std::thread thread_a(&Person::a, this, std::ref(running), std::ref(sum), param2);std::this_thread::sleep_for(std::chrono::seconds(3));if (running.load()) {std::cout << "stop" << std::endl;running = false;}// 等待线程完成执行if (thread_a.joinable()) {thread_a.join();}std::cout << "sum: " <<sum<< std::endl;}std::cout << "任务结束" << std::endl;}
int main() {Person person;person.startA(42, 3.14, "Hello");// ... 其他代码 ...return 0;
}

修改:

在每次循环、处理小任务、遍历某数据 中 进行running判断

#include <iostream>
#include <thread>
#include <atomic>
#include <chrono>
#include <string>
#include "osg.h"void Person::a(std::atomic<bool>& running, int& sum, const double &param2) {std::cout << "Function a started with params " << sum << ", " << param2 << std::endl;// 模拟耗时操作for (int i = 0; i < 10; i++) {if (!running) break;std::this_thread::sleep_for(std::chrono::seconds(1));sum = i;}std::cout << "Function a ended." << std::endl;}void Person::startA(int param1, double param2, const std::string& param3) {for (int i = 0; i < 2; i++) {int sum = 0;std::atomic<bool> running(true);// 创建并启动线程std::thread thread_a(&Person::a, this, std::ref(running), std::ref(sum), param2);std::this_thread::sleep_for(std::chrono::seconds(3));if (running.load()) {std::cout << "stop" << std::endl;running = false;}// 等待线程完成执行if (thread_a.joinable()) {thread_a.join();}std::cout << "sum: " <<sum<< std::endl;}std::cout << "任务结束" << std::endl;}
int main() {Person person;person.startA(42, 3.14, "Hello");// ... 其他代码 ...return 0;
}

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/658090.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

设计模式篇---备忘录模式

文章目录 概念结构实例总结 概念 备忘录模式&#xff1a;在不破坏封装的前提下捕获一个对象的内部状态&#xff0c;并在该对象之外保存这个状态&#xff0c;像这样可以在以后将对象恢复到原先保存的状态。 就好比我们下象棋&#xff0c;下完之后发现走错了&#xff0c;想要回退…

Unity 自动轮播、滑动轮播

如图所示&#xff0c;可设置轮播间隔&#xff0c;可左右滑动进行轮播 1.在UGUI创建个Image&#xff0c;添加自动水平组件 2.添加并配置脚本 3.代码如下&#xff0c;都有注释 using UnityEngine; using UnityEngine.UI;public class IndicatorManager : MonoBehaviour {public …

【乳腺肿瘤诊断分类及预测】基于LVQNN学习向量量化神经网络

课题名称&#xff1a;基于LVQ神经网络的乳腺肿瘤诊断&#xff08;类型分类&#xff09; 版本日期&#xff1a;2023-03-10 运行方式: 直接运行0501_LVQ0501.m 文件即可 代码获取方式&#xff1a;私信博主或QQ&#xff1a;491052175 模型描述&#xff1a; 威斯康辛大学医学院…

(HAL)STM32F407ZGT6——10-4 高级定时器 PWM 输入模式实验

一、高级定时器简介 高级定时器的框图和通用定时器框图很类似&#xff0c;只是添加了其它的一些功能&#xff0c;如&#xff1a;重复计数器、带死区控制的互补输出通道、断路输入等。 高级定时器的时钟来自APB2, 而PCLK2 168Mhz, 我们设置PPRE2不分频, 因此高级定时器时钟 …

使用.NET6 Avalonia开发跨平台三维应用

本文介绍在Vistual Studio 2022中使用Avalonia和集成AnyCAD Rapid AvaloniaUI三维控件的过程。 0 初始化环境 安装Avalonia.Templates dotnet new install Avalonia.Templates若之前安装过可忽略此步骤。 1 创建项目 选择创建AvaloniaUI项目 选一下.NET6版本和Avalonia版…

detectron2的read_image方法

在看代码的时候&#xff0c;看到一行注释&#xff1a;use PIL, to be consistent with evaluation 说是用PIL方法加载&#xff0c;却又看见了BGR这种表述&#xff0c;后面的调用也都是cv2格式&#xff1a; 那我就要看下这里面是怎么实现的了&#xff0c;找到了read_image函数&…

[R] Why data manipulation is crucial and sensitive?

What does a data scientist really do? Identifying the pattern in cultural consumption, making fancy graph, engage a dialogue between data and the existing literature, refining hypothesis….(done within one months with three to four online meetings with p…

【涵子来信】——拆机,感想

大家好&#xff0c;我是涵子。 初中的第一个学期结束了&#xff0c;来临寒假。我在寒假做了一件有趣的事情&#xff1a;拆机&#xff0c;修手机。今天我来分享分享这件事情。 拆机 情况介绍 拆机对象&#xff1a; iPhone 6 Plus 情况&#xff1a; 电池健康度100%&#xff08…

Unity-WebGL

问题&#xff1a;提示gzip压缩报错解决&#xff1a;关闭打包的地方压缩&#xff0c;如下图问题&#xff1a;窗口未全屏解决&#xff1a;使用百分比画布替换固定尺寸画布 参考&#xff1a;新版Unity打包Webgl端进行屏幕自适应_unity webgl分辨率自适应-CSDN博客问题&#xff1a;…

Springboot+Redis

首先前提我们要在自己的本机电脑或者服务器上安装一个redis的服务器 Redis配置 添加依赖: <!-- SpringBoot Boot Redis --> <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artif…

Linux Archcraft结合内网穿透实现SSH远程连接

文章目录 1. 本地SSH连接测试2. Archcraft安装Cpolar3. 配置 SSH公网地址4. 公网远程SSH连接5. 固定SSH公网地址6. SSH固定地址连接7. 结语 Archcraft是一个基于Arch Linux的Linux发行版&#xff0c;它使用最简主义的窗口管理器而不是功能齐全的桌面环境来提供图形化用户界面。…

JVM 内存模型

1 什么是 JVM 内存模型 JVM 需要使用计算机的内存&#xff0c;Java 程序运行中所处理的对象或者算法都会使用 JVM 的内 存空间&#xff0c;JVM 将内存区划分为 5 块&#xff0c;这样的结构称之为 JVM 内存模型。 2 JVM 为什么进行内存区域划分 随着对象数量的增加&#xff…

马哈鱼SQLFlow Lite的python版本

Gudu SQLFlow 是一款用来分析各种数据库的 SQL 语句和存储过程来获取复杂的数据血缘关系并进行可视化的工具。 Gudu SQLFlow Lite version for python 可以让 python 开发者把数据血缘分析和可视化能力快速集成到他们自己的 python 应用中。 Gudu SQLFlow Lite version for p…

Banana Pi BPI-R4开源路由器开发板快速上手用户手册,采用联发科MT7988芯片设计

介绍 Banana Pi BPI-R4 路由器板采用 MediaTek MT7988A (Filogic 880) 四核 ARM Corex-A73 设计&#xff0c;4GB DDR4 RAM&#xff0c;8GB eMMC&#xff0c;板载 128MB SPI-NAND 闪存&#xff0c;还有 2x 10Gbe SFP、4x Gbe 网络端口&#xff0c;带 USB3 .2端口&#xff0c;M.2…

计算机服务器中了halo勒索病毒怎么办,halo勒索病毒解密

在网络技术飞速发展的今天&#xff0c;越来越多的企业依赖数字化办公&#xff0c;为企业的生产生活提供了极大便利&#xff0c;但网络是一把双刃剑&#xff0c;网络安全威胁无处不在。近期&#xff0c;云天数据恢复中心接到很多企业的求助&#xff0c;企业的计算机服务器中了ha…

【Java】实现图书管理系统

文章目录 1. 设计背景2. 需求分析3. 设计思路4. 实现4.1 book包4.1.1 Book类4.1.2 BookList类(书架) 4.2 user包4.2.1 User 类4.2.2 AdminUser类&#xff08;管理员用户&#xff09;4.2.3 NormalUser类&#xff08;普通用户&#xff09; 4.3 operation包4.3.1 IOPeration接口4.…

Maven基本使用

Maven简介: Apache Maven 是一个项目管理和构建工具&#xff0c;它基于项目模型(POM)的概念&#xff0c;通过一小段描述信息来管理项目的构建&#xff0c;报告和文档 Maven的作用: (1&#xff09;项目搭建&#xff1b; &#xff08;2&#xff09;依赖管理&#xff1b; &#xf…

Mac Monitor:一款为macOS安全研究量身定制的高级独立系统监控工具

关于Mac Monitor Mac Monitor是一款功能强大的高级独立系统安全监控工具&#xff0c;该工具专为macOS安全研究、恶意软件分类和系统故障排除而设计&#xff0c;主要基于Apple Endpoint Security&#xff08;ES&#xff09;实现其功能。 Mac Monitor能够收集各种类型的系统事件…

ASP.NET Core 过滤器 使用依赖项注入

过滤器是 ASP.NET Core 中的特殊组件&#xff0c;允许我们在请求管道的特定阶段控制请求的执行。这些过滤器在中间件执行后以及 MVC 中间件匹配路由并调用特定操作时发挥作用。 简而言之&#xff0c;过滤器提供了一种在操作级别自定义应用程序行为的方法。它们就像检查点&#…

CCF CSP 202312-2因子化简

题目描述 样例 输入 3 2155895064 3 2 2 10000000000 10 输出 2238728 1 10000000000 基本思路 首先&#xff0c;要找出构成n的所有素因子&#xff0c;这些因子满足两个条件&#xff1a;是素数&#xff08;函数判断&#xff09;&#xff0c;且能被n或n的中间值整除&#xf…