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吧
尝试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函数中,线程函数名之后的一个参数就是线程参数。你可以将变量取地址作为参数,也可以将多个变量形成的数据结构变量取地址作为参数