我需要在C++程序中并行化一些任务,并且对并行编程来说是全新的.到目前为止,我通过互联网搜索取得了一些进展,但现在有点卡住了.我想在循环中重用一些线程,但显然不知道如何做我正在尝试的东西.
我从计算机上的两个ADC卡(并行获取)中获取数据,然后我需要对收集的数据(并行处理)执行一些操作,同时收集下一批数据.这是一些伪代码来说明
//Acquire some data, wait for all the data to be acquired before proceeding
std::thread acq1(AcquireData, boardHandle1, memoryAddress1a);
std::thread acq2(AcquireData, boardHandle2, memoryAddress2a);
acq1.join();
acq2.join();
while(user doesn't interrupt)
{
//Process first batch of data while acquiring new data
std::thread proc1(ProcessData,memoryAddress1a);
std::thread proc2(ProcessData,memoryAddress2a);
acq1(AcquireData, boardHandle1, memoryAddress1b);
acq2(AcquireData, boardHandle2, memoryAddress2b);
acq1.join();
acq2.join();
proc1.join();
proc2.join();
/*Proceed in this manner, alternating which memory address
is written to and being processed until the user interrupts the program.*/
}
这是它的主要要点.循环的下一次运行将写入"a"内存地址,同时处理"b"数据并继续交替(我可以获取代码来执行此操作,只是将其取出以防止混乱问题).
无论如何,问题(我确信有些人已经知道)是我第二次尝试使用acq1和acq2时,编译器(VS2012)说"IntelliSense:没有适当的操作符调用类类型的对象( )或转换函数到指针到函数类型".同样,如果我将std :: thread再次放在acq1和acq2之前,它会显示"错误C2374:'acq1':重新定义;多次初始化".
所以问题是,我可以在完成上一个任务后将线程重新分配给新任务吗？我总是等待先前使用线程结束再次调用之前,但我不知道如何重新分配线程,因为它在循环中,我不能每次都创建一个新线程(或者如果我可能,这似乎是浪费和不必要的,但我可能会弄错).
提前致谢