多个线程如何轮流输出1到100

2024-09-07 20:44
文章标签 输出 线程 100 多个 轮流

本文主要是介绍多个线程如何轮流输出1到100,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

多个线程如何轮流输出1到100的值

这个面试问题主要考察如何让线程同步,首先线程同步必会用到的就是互斥锁,互斥锁保证多个线程对数据的同时操作不会出错。但是线程同步还会用到条件变量condition_variablecondition_variable(条件变量)是 C++11 中提供的一种多线程同步机制,它允许一个或多个线程等待另一个线程发出通知,以便能够有效地进行线程同步。

condition_variable 需要与 mutex(互斥锁)一起使用。当线程需要等待某个条件变成真时,它会获取一个互斥锁,然后在条件变量上等待,等待期间会自动释放互斥锁。另一个线程在满足条件后会获取相同的互斥锁,并调用条件变量的 notify_one() 或 notify_all() 函数来唤醒等待的线程。

下面我们看一下这个例子

#include <iostream>
#include <mutex>
#include <thread>
#include <condition_variable>std::mutex mtx;
std::condition_variable cv;
int count = 1;  // 记录当前应该输出的数组void printNumber(int thread_id, int start, int end) {while (true) {std::unique_lock<std::mutex> lock(mtx); // 上锁cv.wait(lock, [&]() { return (count-1) % 3 == thread_id || count > 100; }); // 等待轮到当前线程或者已经结束if (count > 100) break;std::cout << thread_id << ": " << count << std::endl;count++; // 输出后递增cv.notify_all(); // 通知其他线程}
}int main() {// 创建三个线程,分别负责不同编号std::thread t1(printNumber, 0, 1, 100);std::thread t2(printNumber, 1, 1, 100);std::thread t3(printNumber, 2, 1, 100);// 等待三个线程结束t1.join();t2.join();t3.join();return 0;
}

这里解释一些代码

cv.wait(lock, [&]() { return (count-1) % 3 == thread_id || count > 100; });// 这里返回true时,线程接着运行,否则的话阻塞在这里,等待notify_all。
// (count-1) % 3 == thread_id 保证正确的线程输出正确的数字
// count > 100 保证线程都可以正确退出
cv.notify_all(); // 通知其他线程// 当前线程结束就直接通知其他线程

请添加图片描述

条件变量condition_variable

std::condition_variable 是 C++ 标准库中的一个同步原语,主要用于线程之间的协调。它帮助实现线程的等待和通知机制,通常与 std::mutex 配合使用。条件变量使得一个线程可以等待另一个线程发出信号,表明某个条件已经发生,从而可以安全地继续执行。

主要成员函数

  1. wait
    • 用法: void wait(std::unique_lock<std::mutex>& lock, Predicate pred);
    • 功能: 阻塞当前线程,直到满足给定的条件 pred。在等待期间,lock 对象所持有的互斥锁会被释放,以便其他线程能够修改共享资源。当条件满足时,线程会重新获取锁,然后继续执行。
    • 参数:
      • lock 是一个 std::unique_lock 对象,它提供了互斥锁的管理。
      • pred 是一个返回布尔值的可调用对象(例如,lambda 表达式),用于检查条件是否满足。
  2. wait_for
    • 用法: template< class Rep, class Period > std::cv_status wait_for(std::unique_lock<std::mutex>& lock, const std::chrono::duration<Rep,Period>& rel_time);
    • 功能: 阻塞当前线程,直到满足条件或指定的时间过去。在时间过去后,如果条件仍未满足,则返回 std::cv_status::timeout
    • 参数:
      • lock 是一个 std::unique_lock 对象。
      • rel_time 是等待的时间段。
  3. wait_until
    • 用法: template< class Clock, class Duration > std::cv_status wait_until(std::unique_lock<std::mutex>& lock, const std::chrono::time_point<Clock,Duration>& timeout_time);
    • 功能: 阻塞当前线程,直到满足条件或到达指定的时间点。如果时间点到达而条件仍未满足,则返回 std::cv_status::timeout
    • 参数:
      • lock 是一个 std::unique_lock 对象。
      • timeout_time 是等待的时间点。
  4. notify_one
    • 用法: void notify_one();
    • 功能: 唤醒一个正在等待的线程。如果有多个线程在等待,具体唤醒哪个线程是由实现决定的。
  5. notify_all
    • 用法: void notify_all();
    • 功能: 唤醒所有正在等待的线程。

std::condition_variable 是用于线程间协调的强大工具。它使得线程可以在某些条件满足之前挂起,而其他线程可以在满足条件时通知这些线程。这对于避免轮询等待和实现高效的线程同步非常有用。

这篇关于多个线程如何轮流输出1到100的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1146116

相关文章

Spring Boot3虚拟线程的使用步骤详解

《SpringBoot3虚拟线程的使用步骤详解》虚拟线程是Java19中引入的一个新特性,旨在通过简化线程管理来提升应用程序的并发性能,:本文主要介绍SpringBoot3虚拟线程的使用步骤,... 目录问题根源分析解决方案验证验证实验实验1:未启用keep-alive实验2:启用keep-alive扩展建

基于Flask框架添加多个AI模型的API并进行交互

《基于Flask框架添加多个AI模型的API并进行交互》:本文主要介绍如何基于Flask框架开发AI模型API管理系统,允许用户添加、删除不同AI模型的API密钥,感兴趣的可以了解下... 目录1. 概述2. 后端代码说明2.1 依赖库导入2.2 应用初始化2.3 API 存储字典2.4 路由函数2.5 应

Java终止正在运行的线程的三种方法

《Java终止正在运行的线程的三种方法》停止一个线程意味着在任务处理完任务之前停掉正在做的操作,也就是放弃当前的操作,停止一个线程可以用Thread.stop()方法,但最好不要用它,本文给大家介绍了... 目录前言1. 停止不了的线程2. 判断线程是否停止状态3. 能停止的线程–异常法4. 在沉睡中停止5

Python实现合并与拆分多个PDF文档中的指定页

《Python实现合并与拆分多个PDF文档中的指定页》这篇文章主要为大家详细介绍了如何使用Python实现将多个PDF文档中的指定页合并生成新的PDF以及拆分PDF,感兴趣的小伙伴可以参考一下... 安装所需要的库pip install PyPDF2 -i https://pypi.tuna.tsingh

python多种数据类型输出为Excel文件

《python多种数据类型输出为Excel文件》本文主要介绍了将Python中的列表、元组、字典和集合等数据类型输出到Excel文件中,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参... 目录一.列表List二.字典dict三.集合set四.元组tuplepython中的列表、元组、字典

Java捕获ThreadPoolExecutor内部线程异常的四种方法

《Java捕获ThreadPoolExecutor内部线程异常的四种方法》这篇文章主要为大家详细介绍了Java捕获ThreadPoolExecutor内部线程异常的四种方法,文中的示例代码讲解详细,感... 目录方案 1方案 2方案 3方案 4结论方案 1使用 execute + try-catch 记录

Spring AI集成DeepSeek实现流式输出的操作方法

《SpringAI集成DeepSeek实现流式输出的操作方法》本文介绍了如何在SpringBoot中使用Sse(Server-SentEvents)技术实现流式输出,后端使用SpringMVC中的S... 目录一、后端代码二、前端代码三、运行项目小天有话说题外话参考资料前面一篇文章我们实现了《Spring

Spring Boot 中正确地在异步线程中使用 HttpServletRequest的方法

《SpringBoot中正确地在异步线程中使用HttpServletRequest的方法》文章讨论了在SpringBoot中如何在异步线程中正确使用HttpServletRequest的问题,... 目录前言一、问题的来源:为什么异步线程中无法访问 HttpServletRequest?1. 请求上下文与线

在 Spring Boot 中使用异步线程时的 HttpServletRequest 复用问题记录

《在SpringBoot中使用异步线程时的HttpServletRequest复用问题记录》文章讨论了在SpringBoot中使用异步线程时,由于HttpServletRequest复用导致... 目录一、问题描述:异步线程操作导致请求复用时 Cookie 解析失败1. 场景背景2. 问题根源二、问题详细分

Rust格式化输出方式总结

《Rust格式化输出方式总结》Rust提供了强大的格式化输出功能,通过std::fmt模块和相关的宏来实现,主要的输出宏包括println!和format!,它们支持多种格式化占位符,如{}、{:?}... 目录Rust格式化输出方式基本的格式化输出格式化占位符Format 特性总结Rust格式化输出方式