C++11多线程异步执行耗时程序
2021/9/11 14:05:53
本文主要是介绍C++11多线程异步执行耗时程序,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!
#include <iostream>
#include <thread>
#include <future>
#include <vector>
#include <mutex>
std::mutex mtx;
using namespace std;
using namespace chrono;
template<typename T>
void Measure(T&& func)
{
auto start = system_clock::now();
func();
duration<double> diff = system_clock::now() - start;
cout << "elapsed: " << diff.count() << "seconds" << endl;
}
int64_t Sum(int64_t start, int64_t end)
{
int64_t s = 0;
for (int64_t i = start; i < end; ++i){
s += i;
}
return s;
}
void Sum1(int &s)
{
mtx.lock();
for (int i=0; i<1000000; ++i){
s++;
}
mtx.unlock();
}
int main(char* argc, char** argv)
{
const int64_t N = 1000000000;
//1和2多线程和单线程操作,耗时比较
//1.异步多线程
Measure([N]() {
const long K = 8;
vector<future<int64_t>> vf;
vf.reserve(K);
for (int i=0; i<K; ++i)
{
vf.push_back(async(Sum, i == 0 ? 0 : (N / K)*i, (N / K)*(i + 1)));
}
int64_t ans = 0;
for (int i = 0; i < K; i++)
{
ans += vf[i].get();
}
cout << ans << endl;
});
//2.单线程
Measure([N]() {
int64_t ans = Sum(0, N);
cout << "ans:" << ans << endl;
});
/////////////////////////////////////////////
//3.多线程加锁,保证原子性
Measure([]() {
vector<thread> v;
int s = 0;
for (size_t i = 0; i < 4; i++)
{
v.emplace_back(Sum1, std::ref(s));
}
for (int i=0; i<v.size(); ++i)
{
v[i].join();
}
cout << "s: " << s << endl;
});
system("pause");
return 0;
}
这篇关于C++11多线程异步执行耗时程序的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!
- 2024-05-15PingCAP 黄东旭参与 CCF 秀湖会议,共探开源教育未来
- 2024-05-13PingCAP 戴涛:构建面向未来的金融核心系统
- 2024-05-09flutter3.x_macos桌面os实战
- 2024-05-09Rust中的并发性:Sync 和 Send Traits
- 2024-05-08使用Ollama和OpenWebUI在CPU上玩转Meta Llama3-8B
- 2024-05-08完工标准(DoD)与验收条件(AC)究竟有什么不同?
- 2024-05-084万 star 的 NocoDB 在 sealos 上一键起,轻松把数据库编程智能表格
- 2024-05-08Mac 版Stable Diffusion WebUI的安装
- 2024-05-08解锁CodeGeeX智能问答中3项独有的隐藏技能
- 2024-05-08RAG算法优化+新增代码仓库支持,CodeGeeX的@repo功能效果提升