点击蓝字
关注我们
C++11 线程创建
每一个 C++11 程序都包含一个主线程即 main() 函数。在 C++11 中我们可以通过创建 std::thread 对象来创建新的线程。
每个 std::thread 对象都可以与一个线程相关联。
需要引用的头文件：
| |
std::thread 的构造函数中接受什么参数？
我们可以给 std::thread 对象添加函数，这个回调函数将在这个新线程启动时执行。这些回调可以是：
1.) 函数指针
2.) 函数对象
3.) Lambda 函数
创建 thread 对象：
| |
新线程将在创建新对象后立即启动，并将并行地执行（当参数）传递给线程的回调函数。
此外，任何线程都可以通过调用某线程对象上的 join( ) 函数来等待此线程退出。
让我们看一个例子，主线程将创建另外一个线程。创建这个新线程后，主线程会在控制台上打印一些数据，然后等待新创建的线程退出。
下面我们使用三种不同回调机制来实现上面的内容。
使用函数指针创建线程
| |
使用函数对象创建线程
| |
使用 Lambda 函数创建线程
| |
如何区分线程
每个 std::thread 对象都有一个 ID，使用下面的函数可以获取：
| |
获取当前线程的 ID：
| |
如果 std::thread 对象没有和任何对象关联，则 get_id() 函数会返回默认构造的 std::thread::id 对象，即“非线程”。
std::thread::id 是一个对象，它也可以在控制台上进行比较和打印。让我们来看一个例子：
| |
std::thread 的搭配用法
std::promise
为了在不同的线程之间传递数据，C++ 引入了 std::promise 和 std::future 这两种数据结构，在头文件 <future> 中包含。
promise 是一个范型的数据结构，你可以定义一个整形的 promise：promise<int>，这意味着线程之间传递的值是整形。
promise 的 get_future() 方法返回一个 future 数据结构，从这个 future 数据结构可以获取设置给 promise 的值，下面是一个例子：
#include <iostream>
#include <future>
#include <thread>using namespace std;int main() {promise<int> a_promise; auto a_future = a_promise.get_future(); a_promise.set_value(10); cout << a_future.get() << endl;cout << "after get()" << endl;return 0;
}上面例子的输出结构是：
10
after get()实际上，上面的例子并没有使用线程，但是很好得展示了 promise 和 future 之间的关系。
更复杂一点的使用场景可能是下面这样子的：
主线程定义一个promise，命名为p
主线程调用p.get_future()，并把返回值保存为引用f
主线程启动一个子线程，并把p作为启动参数传给子线程
主线程调用f.get()，但是此时子线程还未将数据放入promise内，所以主线程挂起
子线程执行完，获取到结果，并把结果写入p
主线程从f.get()的调用中被唤醒，获取到子线程写入p的值，继续执行
std::packaged_task
C++11很贴心地提供了packaged_task类型，让我们不用直接使用std::thread和std::promise，直接就能够生成线程，派遣任务：
#include <iostream>
#include <future>using namespace std;int f() {string hi = "hello, world!";cout << hi << endl;return hi.size();
}int main() {packaged_task<int ()> task(f);auto result = task.get_future();task();cout << result.get() << endl;return 0;
}上面代码的运行结果为：
hello, world!
13std::async
std::packaged_task 要求你自己启动任务，比如上一章节例子中你要显示调用 task()。如果连这一步都想省了的话，可以使用 std:async:
#include <iostream>
#include <vector>
#include <algorithm>
#include <numeric>
#include <future> template <typename RandomIt>int parallel_sum(RandomIt beg, RandomIt end)
{auto len = end - beg;if (len < 1000) return std::accumulate(beg, end, 0);RandomIt mid = beg + len/2;auto handle = std::async(std::launch::async,parallel_sum<RandomIt>, mid, end);int sum = parallel_sum(beg, mid);return sum + handle.get();
}int main()
{std::vector<int> v(10000, 1);std::cout << "The sum is " << parallel_sum(v.begin(), v.end()) << '\n';
}上面的代码来自 cpp reference ，运行结果：The sum is 10000。
std::this_thread
C++11专门提供了一个命名空间std::this_thread来表示当前线程。std::this_thread提供了几个方法可以对线程做一定的控制：
get_id()，获取线程id
yield(), 释放执行权
sleep_for()，使线程沉睡一定时间
…
下面是一个具体例子：
#include <iostream>#include <future>#include <thread>using namespace std;int f(promise<int> my_promise) {string hi = "hello, world!";my_promise.set_value(hi.size());this_thread::sleep_for(0.1s);cout << hi << endl;
}int main() {promise<int> f_promise;auto result = f_promise.get_future();thread f_thread(f, move(f_promise));cout << result.get() << endl;f_thread.join();return 0;
}*声明：本文于网络整理，版权归原作者所有，如来源信息有误或侵犯权益，请联系我们删除或授权事宜。
戳“阅读原文”我们一起进步
