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

Question

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

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吧

尝试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个参数
各位可以解决吗，或者有其他办法吗？

Answer 1

你的多线程是有问题的，开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());
        }
    }
}