当前位置: 首页 > ai >正文

c++,linux,多线程编程详细介绍

目录

    • 一、基础概念
    • 二、POSIX线程(pthread)
    • 三、C++11标准库<thread>
    • 四、同步机制详解
    • 五、异步编程模型
    • 六、线程池实现
    • 七、代码示例

在Linux环境下使用C++进行多线程编程,可利用POSIX线程(pthread)或C++11标准库。以下从基础概念、同步机制、异步编程模型、线程池等方面进行详细介绍:

一、基础概念

线程是进程中的执行单元,共享进程的地址空间和数据,但拥有独立的执行栈和寄存器状态。多线程编程可提高程序响应性、充分利用多核资源,但需注意线程安全和资源竞争问题。

二、POSIX线程(pthread)

  • 线程创建:使用pthread_create函数创建线程,需指定线程函数、参数和属性。
  • 线程同步:
    • 互斥锁:使用pthread_mutex_t保护共享资源,避免数据竞争。
    • 条件变量:使用pthread_cond_t实现线程间的等待和通知机制。
  • 线程退出与等待:线程可通过pthread_exit退出,主线程使用pthread_join等待子线程结束。

三、C++11标准库

  • 线程创建:使用std::thread构造函数直接创建线程,支持函数指针、Lambda表达式和类成员函数。
  • 线程管理:
    • join():等待线程结束。
    • detach():分离线程,使其在后台独立运行。
  • 同步机制:
    • 互斥锁:使用std::mutex保护共享资源。
    • 条件变量:使用std::condition_variable实现线程间的同步。
    • 原子操作:使用std::atomic确保对变量的操作是线程安全的。

四、同步机制详解

  • 互斥锁:确保同一时间只有一个线程访问共享资源。
  • 条件变量:用于线程间的通信,允许线程等待某个条件成立。
  • 读写锁:允许多个线程同时读取共享资源,但在写入时阻止其他线程访问。
  • 屏障:确保多个线程在某个点上同步,所有线程都到达屏障点后才能继续执行。

五、异步编程模型

  • 回调函数:将函数作为参数传递给异步操作,操作完成后调用该函数处理结果。
  • 异步函数:使用std::async创建异步任务,返回std::future对象用于获取结果。
  • 线程池:管理线程的创建和销毁,避免频繁创建和销毁线程的开销。

六、线程池实现

线程池通过预创建一组线程,并将任务提交到任务队列中,由空闲线程执行任务。线程池可有效管理线程资源,提高程序性能。

七、代码示例

使用和互斥锁:

#include <iostream>
#include <thread>
#include <mutex>std::mutex mtx;
int shared_data = 0;void thread_func() {std::unique_lock<std::mutex> lock(mtx);shared_data++;
}int main() {std::thread t1(thread_func);std::thread t2(thread_func);t1.join();t2.join();std::cout << "Shared data: " << shared_data << std::endl;return 0;
}

使用条件变量:

#include <iostream>
#include <thread>
#include <mutex>
#include <condition_variable>std::mutex mtx;
std::condition_variable cv;
bool ready = false;void producer() {std::unique_lock<std::mutex> lock(mtx);ready = true;cv.notify_one();
}void consumer() {std::unique_lock<std::mutex> lock(mtx);while (!ready) {cv.wait(lock);}std::cout << "Data is ready." << std::endl;
}int main() {std::thread t1(producer);std::thread t2(consumer);t1.join();t2.join();return 0;
}
http://www.xdnf.cn/news/6687.html

相关文章:

  • FC7300 ADC采样理论介绍
  • 宽河道流量监测——阵列雷达波测流系统如何监测河道流量
  • GTS-400 系列运动控制器板卡介绍(三十六)--- 电机到位检测功能
  • Ubuntu 22.04 上安装 Drupal 10并配置 Nginx, mysql 和 php
  • Java 多线程基础:Thread 类核心用法详解
  • E-R图合并时的三种冲突
  • SDT-5土体动力特性测试系统
  • 工具生态构建对比分析
  • 进阶-数据结构部分:1、数据结构入门
  • ASP.NET/IIS New StreamContent(context.Request.InputStream) 不会立即复制整个请求流的内容到内存
  • 什么是本地事务,什么是分布式事务
  • 【MATLAB例程】线性卡尔曼滤波的程序,三维状态量和观测量,较为简单,可用于理解多维KF,附代码下载链接
  • ESP32开发之freeRTOS的任务通知
  • OpenCV CUDA模块中矩阵操作------归一化与变换操作
  • window nvidia-smi命令 Failed to initialize NVML: Unknown Error
  • 【学习笔记】因果推理导论第1课
  • 3D一览通为山东融科MES系统补全车间看图能力
  • 车道线检测----CLRNet
  • Elasticsearch倒排索引核心原理面试题
  • 视频孪生智慧风电场解决方案
  • 【C++/Qt shared_ptr 与 线程池】合作使用案例
  • 模板分享:网络最小费用流
  • css:倒影倾斜效果
  • Jenkins 最佳实践
  • 从数据包到可靠性:UDP/TCP协议的工作原理分析
  • 【localstorage、sessionStorage和cookie】
  • python报错:typeerror:type object is not subcriptable问题原因及解决方案
  • socket通信中的accept函数
  • 【vue】封装接口,全局字典,表格表头及使用
  • 子查询对多层join优化记录