易小侠
2021-09-01 11:32
采纳率: 90%
浏览 81

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

  • 收藏

4条回答 默认 最新

  • sanzhong104204 2021-09-02 13:55
    已采纳

    你的多线程是有问题的,开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());
            }
        }
    }
    
    
    
    已采纳该答案
    打赏 评论
  • CSDN专家-link 2021-09-01 11:55

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

    打赏 评论
  • CSDN专家-link 2021-09-01 13:42

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

    打赏 评论

相关推荐 更多相似问题