标签：COUNT int cpus C++ batch ++ 并行计算 async include

并行计算使用的是async, 通过每一个线程都进行相同的计算，最后在vector<future<int>>result; 将结果进行相加

全部代码

//
// Created by Administrator on 2021/6/29.
//
#include<iostream>
#include<thread>
#include<future>
#include<vector>
#include<cstdlib>


using namespace std;
#define COUNT 1000000

int add(vector<int>*arr, int start, int count)
{
    static mutex m; //只会初始化一次
    int sum(0); //保存结果的作用
    for(int i = 0; i < count; i++){
        sum += (*arr)[start + i];
    }
    {
        //显示结果必须, 仅仅计算多余, 加锁
        lock_guard<mutex> lck(m); //锁定
        cout << "thread" << this_thread::get_id << ",count" <<
        ",sum=" << sum << endl; //打印结果
    }
    return sum;
}


int main()
{
    vector<int>data(COUNT); //数组, 100万
    for(int i = 0; i < COUNT; i++)
    {
        data[i] = (i + 1) % 1000; //0-999
    }

    vector<future<int>>result; //结果数组
    int cpus = thread::hardware_concurrency(); //CPU核心的个数
    for(int i = 0; i < cpus * 2; i++)
    {
        int batch_each = COUNT / (cpus * 2); //
        if(i == (cpus * 2) - 1) {
            batch_each = COUNT - COUNT / (cpus * 2) * i; //最后一个承担更多的计算
        }
        //不断压入结果
        result.push_back(async(add, &data, i * batch_each, batch_each)); //返回结果
    }
    int lastresult(0);
    for(int i = 0; i < cpus * 2; i++)
    {
        lastresult += result[i].get();  //汇总结果
    }
    cout << "lastresult=" << lastresult << endl;
    cin.get();
}

//
// Created by Administrator on 2021/6/29.
//
#include<iostream>
#include<thread>
#include<future>
#include<vector>
#include<cstdlib>


using namespace std;
#define COUNT 1000000

int add(vector<int>*arr, int start, int count)
{
    static mutex m; //只会初始化一次
    int sum(0); //保存结果的作用
    for(int i = 0; i < count; i++){
        sum += (*arr)[start + i];
    }
    {
        //显示结果必须, 仅仅计算多余, 加锁
        lock_guard<mutex> lck(m); //锁定
        cout << "thread" << this_thread::get_id << ",count" <<
        ",sum=" << sum << endl; //打印结果
    }
    return sum;
}


int main()
{
    vector<int>data(COUNT); //数组, 100万
    for(int i = 0; i < COUNT; i++)
    {
        data[i] = (i + 1) % 1000; //0-999
    }

    vector<future<int>>result; //结果数组
    int cpus = thread::hardware_concurrency(); //CPU核心的个数
    for(int i = 0; i < cpus * 2; i++)
    {
        int batch_each = COUNT / (cpus * 2); //
        if(i == (cpus * 2) - 1) {
            batch_each = COUNT - COUNT / (cpus * 2) * i; //最后一个承担更多的计算
        }
        //不断压入结果
        result.push_back(async(add, &data, i * batch_each, batch_each)); //返回结果
    }
    int lastresult(0);
    for(int i = 0; i < cpus * 2; i++)
    {
        lastresult += result[i].get();  //汇总结果
    }
    cout << "lastresult=" << lastresult << endl;
    cin.get();
}

标签：COUNT,int,cpus,C++,batch,++,并行计算,async,include
来源： https://www.cnblogs.com/my-love-is-python/p/14948191.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。