C++怎么批量调用某个带参数的线程函数?

C++怎么批量调用某个带参数的线程函数?

问题描述:

我先说下场景吧,就是要下面打印出来

int main()
{
    int size=10000;
    for(size_t i = 0; i < size; ++i)
          for(int j=i+1;i<size;j++)
                 cout<<to_string(i)<<"+"<<to_string(j)<<"="<<i+j<<endl;
}

循环打印时间太长了,我想这样优化:
把下面这段代码搞成size个线程同时执行,可以不用管打印的顺序,只要全部打印出来就行:
for(int j=i+1;i<size;j++)
cout<<to_string(i)<<"+"<<to_string(j)<<"="<<i+j<<endl;

尝试1:

void calculate(int index,int size)
{
    for(int i=index+1;i<size;i++)
          cout<<to_string(i)<<"+"<<to_string(index)<<"="<<i+index<<endl;
}

int main{}
{
    int size=10000;
    std::vector<string>task(size);
    for (size_t i = 0; i < size; ++i)
    {
       std::cout << "遍历:" << i << endl;
       task[i] = "task" + to_string(i);
       std::thread task[i](calculate, i,size); //这里报错
    }
}

报错,你不可能写1万次 std::thread task1,到std::thread task10000吧
img

尝试2:

void calculate(int index,int size)
{
    for(int i=index+1;i<size;i++)
          cout<<to_string(i)<<"+"<<to_string(index)<<"="<<i+index<<endl;
}
int main{}
{
    int size=10000;
    std::vector<string>task(size);
    for (size_t i = 0; i < size; ++i)
    {
       std::cout << "遍历:" << i << endl;
       HANDLE* hThread1;
       hThread1[i] = CreateThread(NULL,0,(LPTHREAD_START_ROUTINE) calculate(i,size),NULL,0, NULL);
    }
}

又报错:void*不能转换成LPTHREAD_START_ROUTINE,CreateThread只有5个参数
各位可以解决吗,或者有其他办法吗?

你的多线程是有问题的,开10000个线程,还好没跑起来,跑起来直接PC挂掉了估计。
std::cout 在多线程下可能是不安全的,打印会乱掉。

建议你把cout 换成存文件,可能会快一点,打印出来的文本有6-7百兆,搁谁谁懵逼

非要多线程,可以试下下面这个

#include <iostream>
#include <sstream>
#include <vector>
#include <string>
#include <thread>
using namespace std;
void calculate(int start, int end,int size)
{
    if (start == 0) start = 1;
    for(int i=start;i<end;i++)
        for (int j = i + 1; j < size;j++)
            cout<<to_string(i)<<"+"<<to_string(j)<<"="<<i+j<<endl;
}

int main()
{
    int size=10000;
    int cpuNum = 4;

    int sliceCount = size / cpuNum;

    std::vector<string> task(cpuNum);
    std::thread *threadTasks[cpuNum];

    for (size_t i = 0; i < cpuNum; ++i)
    {
        std::cout << "遍历:" << i << endl;
        task[i] = "task" + to_string(i);
        threadTasks[i] = new std::thread(calculate, i * sliceCount, (i + 1) * sliceCount, size); //这里报错
    }

    for (size_t i = 0; i < cpuNum; ++i) {
        threadTasks[i]->join();
    }

    return 0;
}

用java,StringBuilder 带缓冲的,在idea下约1min跑完

package com.xx;

public class Main {

    public static void main(String[] args) {
        int size = 10000;

        for (int i = 0; i < size; ++i) {
            StringBuilder stringBuilder = new StringBuilder();
            for (int j = i + 1; j < size; j++) {
                stringBuilder.append(i)
                        .append('+')
                        .append(j)
                        .append('=')
                        .append(i + j)
                        .append('\n');
            }
            System.out.print(stringBuilder.toString());
        }
    }
}


线程中只需要写函数名就行了,不要带参数。
你的calculate函数不符合线程函数格式要求

线程函数参数只能是void *类型,在CreateThread函数中,线程函数名之后的一个参数就是线程参数。你可以将变量取地址作为参数,也可以将多个变量形成的数据结构变量取地址作为参数