C++11多线程初体验

在C++11标准之前,使用C++编写多线程程序要么需要第三方的API如pthread,要么需要依赖运行平台提供的API,使用起来很不方便。而C++11提供了平台无关的语言级别的支持,这极大得方便了我们开发人员。

C++11的多线程支持主要通过使用如下的头文件中的类或者函数:<atomic><thread><mutex><condition_variable><future>。


新建线程

通过std::thread类新建线程。一般有两种方式:

1) 传递一个函数(可以是函数指针或者Lambda表达式等)

2) 传递一个对象,该对象重载了操作符(),也可以说该对象中必须有一个名为operator()的函数。

下面看实例(Visual Studio 2015运行通过):

#include <thread>
#include <iostream>

using namespace std;

// 一个普通的函数
void fun(int num)
{
    cout << "The function child thread begin...\n";
    cout << "I come from function fun(): " << num << ‘\n‘;
    cout << "The function child thread end...\n";
    cout << endl;
}

// 一个函数类,实现了operator()方法
class Fun
{
public:
    void operator()(int num)
    {
        cout << "The class child thread begin...\n";
        cout << "I come from class Fun: " << num << ‘\n‘;
        cout << "The class child thread end...\n";
        cout << endl;
    }
};

int main()
{
    cout << "Main thread begin..." << ‘\n‘;
    cout.sync_with_stdio(true); // 设置输入流cout是线程安全的
    thread t_1(fun, 1); // 新建线程,第一个参数是函数指针,第二个参数是函数的参数(第二个参数是可变长参数)
    t_1.join(); // join方法数会阻塞主线程直到目标线程调用完毕,即join会直接执行该子线程的函数体部分
    thread t_2(fun, 2);
    t_2.detach(); // detach方法不会阻塞任何线程,目标线程就成为了守护线程,驻留后台运行
    Fun oFun;
    thread t_3(ref(oFun), 3); //这里新建线程,使用对象进行初始化,这里的通过ref传递的是oFun本身而不是其拷贝
    t_3.join();
    cout << "Main thread end..." << endl;
    return 0;
}

运行结果:

可以看到先执行主线程,然后是t_1子线程,然后是t_2子线程,但是t_2子线程没有执行完毕,又开始执行t_3子线程,等t_3执行完毕,接着执行t_2,然后是结束主线程。

为什么会是这样的结果呢?因为t_1和t_3调用的是thread的join方法,而t_2调用的是detach方法。

join()等待该子线程执行完之后,主线程才可以继续执行下去,此时主线程会释放掉执行完后的子线程资源。而detach()将子线程从主线程里分离,成为一个后台线程,子线程执行完成后会自己释放掉资源。分离后的线程,主线程将对它没有控制权了。


线程同步问题

一提到线程,一定会有资源竞争,以及死锁活锁的问题。

C++中提供atomic保持变量的原子性,个人感觉有些类似于Java和C#中的volatile关键字。

下面看这样一个例子:

#include <thread>
#include <iostream>
#include <vector>

using namespace std;

void func(int& counter)
{
    for (int i = 0; i < 100000; ++i)
    {
        ++counter;
    }
}

int main()
{
    int counter = 0;
    vector<thread> threads;
    for (int i = 0; i < 10; ++i)
    {
        threads.push_back(thread(func, ref(counter)));
    }
    for (auto& current_thread : threads)
    {
        current_thread.join();
    }
    cout << "Result = " << counter << ‘\n‘;
    return 0;
}

你多执行几次,会发现每次输出的counter的值并不总是1000000(100000*10=1000000,10个线程,每个线程每次增加100000),为什么呢?这就涉及到多线程中资源的竞争问题。

那么如何解决这个问题呢?C++中提供了atomic类,看修改后的程序:

#include <thread>
#include <iostream>
#include <vector>
#include <atomic>

using namespace std;

void func(atomic<int>& counter)
{
    for (int i = 0; i < 100000; ++i)
    {
        ++counter;
    }
}

int main()
{
    atomic<int> counter(0);
    vector<thread> threads;
    for (int i = 0; i < 10; ++i)
    {
        threads.push_back(thread(func, ref(counter)));
    }
    for (auto& current_thread : threads)
    {
        current_thread.join();
    }
    cout << "Result = " << counter << ‘\n‘;
    return 0;
}

这样执行上面程序不管多少次输出总是:Result = 1000000

此外,atomic类还提供了封装好的一些函数操作,详见:C++参考-atomic

初始C++多线程,就写到这里。

时间: 2024-10-11 00:30:17

C++11多线程初体验的相关文章

java的多线程初体验

这里以车站售票作为模拟场景,多个票务人员同时出售某一列高铁(G250?)的车票,售票的基本保证有2点: 1.不能售出多于预定限额的车票. 2.不能售出具有相同座位的车票. 初学java,有不当的地方各位看官请指教~ 代码如下: package threadjava; public class ThreadTest4 { public static void main(String[] args) { // TODO 自动生成的方法存根 //限定总票数为100张 Seller seller = n

stm32f7 rtems4.11.3初体验

开发环境 开发板: 正点原子apollo底板配stm32f767核心版 调试工具: openocd + jlink + eclipse rtems版本: 4.11.3 测试步骤 测试目标: 运行testsuits下的hello.exe 为了方便调试,将hello.exe运行于stm32的内存中而不是下载到片上flash里 需要修改stm32的连接文件 简单期间直接在stm32f4的bsp上改 打开rtems-4.11.3/c/src/lib/libbsp/arm/stm32f4/startup/

Linux多线程初体验

直接上代码 #include "pthread.h" //线程库,线程不是通过内核实现的 #include "stdio.h" #include "stdlib.h" #include "unistd.h" void* thread_func(void *arg){ int *val = (int*)arg; printf("Hi!I'm a thread!\n"); if(NULL != arg){ pr

【Spark深入学习 -15】Spark Streaming前奏-Kafka初体验

----本节内容------- 1.Kafka基础概念 1.1 出世背景 1.2 基本原理 1.2.1.前置知识 1.2.2.架构和原理 1.2.3.基本概念 1.2.4.kafka特点 2.Kafka初体验 2.1 环境准备 2.2 Kafka小试牛刀 2.2.1单个broker初体验 2.2.2 多个broker初体验 2.3 Kafka分布式集群构建 2.3.1 Kafka分布式集群构建 2.3.2 Kafka主题创建 2.3.3 生产者生产数据 2.3.4消费者消费数据 2.3.5消息的

Oracle SQL篇(一)null值之初体验

    从我第一次正式的写sql语句到现在,已经超过10年的时间了.我写报表,做统计分析和财务对账,我一点点的接触oracle数据库,并尝试深入了解.这条路,一走就是10年,从充满热情,到开始厌倦,我不知道我还能坚持多久,未来的路,谁知道呢? 也许是该抓紧时间,做一点什么了,我不知道该开始写些什么,我从来没有在网上写东西的习惯.     先从简单的开始吧,那当然就是SQL,这是我SQL系列的第一篇,希望我能够坚持. 在Oracle数据库中,如果一个表中的列没有值的话,我们可以说是空值,比如IT员

C++11多线程教学(二)

转载自:http://www.cnblogs.com/lidabo/p/3908713.html C++11多线程教学II 从我最近 发布的C++11线程教学文章里,我们已经知道C++11线程写法与POSIX的pthreads写法相比,更为简洁.只需很少几个简单概念,我们就能搭 建相当复杂的处理图片程序,但是我们回避了线程同步的议题.在接下来的部分,我们将进入C++11多线程编程的同步领域,看看如何来同步一组并行的线程. 我们快速回顾一下如何利用c++11创建线程组.上次教学当中,我们用传统c数

leaflet开源地图库源码阅读笔记(一)——简介&amp;Demo初体验(by vczero)

一.简介 电子地图已经在O2O.生活服务.出行等领域布局,传统的GIS也孕育着互联网基因.传统GIS的图商有ESRI(Arc系列).四维.高德.超图.中地等等.在web互联网领域,百度和高德较为出色.但是开放源代码都远远做的不够,相比而言国外开源较多且丰富,最近认真研读了openlayers2/3和leaflet的源码,收获颇多,不仅加强对浏览器兼容性.HTML5.CSS3等基础,还增强了GIS的基础.本人现在也在一家互联网公司做js api的研发,因此,需要不断地吸取开源代码的营养. leaf

树莓派2代B model 上手初体验,不用显示器,Python GPIO 点亮一颗LED

开题:[好东西,值得研究!] 标题:树莓派2代B model 上手初体验,不用显示器,Python GPIO 点亮一颗LED [知识普及] 1,树莓派各版本对比: 2,树莓派2代BModel 主板,图样 树莓派2 代B GPIO 图 [所需硬件] 一张TF卡,8G或者8G以上,我的是 [三星TF卡16g class10 EVO] 一根网线,让树莓派与路由器连接 一个5V 500MA 的普通USB电源,为树莓派供电 ,我试过了,5V 500ma没问题 一个树莓派2代B 一个普通路由器[如果你连路由

1Python全栈之路系列之Django初体验

Python全栈之路系列之Django初体验 Django不得不说在Python中是一个非常强大的全栈框架,而且入门也比较简单,只要你学完了基本的Django知识,接着再做一两个项目,不大不小就成,然后你再去学其它的框架你会发现,在那些小而美的框架中,你学起来将非常的快,因为你在学习Django的时候就已经学习并且体验过了Web开发流程,所以会有这么一个现象出现,有些新手朋友在学习Flask.Tornado等小而美的框架时,很多概念不是很理解,比如ORM.路由等,但你学Django就不会出现这种