我正在尝试在并行 for 循环中实现任务状态报告功能。这种 for 循环的并行化是使用“OPENMP”执行的。
我希望像这样执行状态报告:
Work done 70%; estimated time left 3:30:05 hour.
当然,我可以通过计算“开始时间”和“当前时间”之间的差异来计算“预计剩余时间”。但是,即使使用“静态”声明,我似乎也无法在 for 循环中准确计算“完成的工作”。
一些指导将不胜感激。
我的代码的输出:
Values of cores : 8
Outer loop =================================
Thread 0 iCount0
% of work done 10
Outer loop =================================
Thread 0 iCount1
Outer loop =================================
Thread 2 iCount2
Outer loop =================================
Thread 7 iCount3
% of work done 40
Outer loop =================================
Thread 5 iCount4
% of work done 50
Outer loop =================================
Thread 3 iCount5
% of work done 60
Outer loop =================================
Thread 4 iCount6
% of work done 70
Outer loop =================================
Thread 1 iCount7
% of work done 20
% of work done 80
Outer loop =================================
Thread 6 iCount8
% of work done 90
Outer loop =================================
Thread 1 iCount9
% of work done 100
% of work done 30
从最后两行输出中可以看出,我无法正确计算作业状态。
这是我的代码:
注意:我故意使用“std::endl”而不是“\n”,因为以某种方式刷新输出缓冲区会干扰我的工作百分比计算。我确信如果我在并行执行实际计算时会出现类似的情况
#include "stdafx.h"
#include <iostream> // std::cout, std::endl
#include <iomanip> // std::setfill, std::setw
#include <math.h> /* pow */
#include <omp.h>
int main(int argc, char** argv)
{
// Get the number of processors in this system
int iCPU = omp_get_num_procs();
// Now set the number of threads
omp_set_num_threads(iCPU);
std::cout << "Values of cores : " << iCPU <<" \n";
int x = 0;
int iTotalOuter = 10;
static int iCount = 0;
#pragma omp parallel for private(x)
for(int y = 0; y < iTotalOuter; y++)
{
std::cout << "Outer loop =================================\n" ;
std::cout <<"\nThread "<<omp_get_thread_num()<<" iCount" << iCount<<std::endl;
for(x = 0; x< 5; x++)
{
//std::cout << "Inner loop \n" ;
}
iCount = iCount + 1;
std::cout <<"\n % of work done " << (double)100*((double)iCount/(double)iTotalOuter)<<std::endl;
}
std::cin.ignore(); //Wait for user to hit enter
return 0;
}
更新: 根据“Avi Ginsburg”的回答,我正在尝试这样做:
#include "stdafx.h"
#include <iostream> // std::cout, std::endl
#include <iomanip> // std::setfill, std::setw
#include <math.h> /* pow */
#include <omp.h>
void ReportJobStatus(int , int );
int main(int argc, char** argv)
{
// Get the number of processors in this system
int iCPU = omp_get_num_procs();
// Now set the number of threads
omp_set_num_threads(iCPU);
std::cout << "Values of cores : " << iCPU <<" \n";
int x = 0;
int iTotalOuter = 100;
static int iCount = 0;
#pragma omp parallel for private(x)
for(int y = 0; y < iTotalOuter; y++)
{
std::cout << "Outer loop =================================\n" ;
for(x = 0; x< 5; x++)
{
//std::cout << "Inner loop \n" ;
}
#pragma omp atomic
iCount++;
std::cout<< " omp_get_thread_num(): " << omp_get_thread_num() <<"\n";
if (omp_get_thread_num() == 0){
ReportJobStatus(iCount, iTotalOuter);
}
}
std::cin.ignore(); //Wait for user to hit enter
return 0;
}
问题(更新):问题是同一个线程被用于并发执行。因此,“已完成工作”报告受到严重限制。如何根据数据将作业分配给不同的核心。
这是我的代码的当前输出:
Outer loop =================================
omp_get_thread_num(): 0
% of work done 1
Outer loop =================================
omp_get_thread_num(): 0
% of work done 2
Outer loop =================================
omp_get_thread_num(): 0
% of work done 3
Outer loop =================================
omp_get_thread_num(): 0
% of work done 4
Outer loop =================================
omp_get_thread_num(): 0
% of work done 5
Outer loop =================================
omp_get_thread_num(): 0
% of work done 6
Outer loop =================================
omp_get_thread_num(): 0
% of work done 7
Outer loop =================================
omp_get_thread_num(): 0
% of work done 8
Outer loop =================================
omp_get_thread_num(): 0
% of work done 9
Outer loop =================================
omp_get_thread_num(): 0
% of work done 10
Outer loop =================================
omp_get_thread_num(): 0
% of work done 11
Outer loop =================================
omp_get_thread_num(): 0
% of work done 12
Outer loop =================================
omp_get_thread_num(): 0
% of work done 13
Outer loop =================================
omp_get_thread_num(): 0
% of work done 14
Outer loop =================================
omp_get_thread_num(): 0
% of work done 15
Outer loop =================================
omp_get_thread_num(): 0
% of work done 16
Outer loop =================================
omp_get_thread_num(): 0
% of work done 17
Outer loop =================================
omp_get_thread_num(): 0
% of work done 18
Outer loop =================================
omp_get_thread_num(): 0
Outer loop =================================
omp_get_thread_num(): 3
Outer loop =================================
omp_get_thread_num(): 3
Outer loop =================================
omp_get_thread_num(): 3
Outer loop =================================
omp_get_thread_num(): 3
Outer loop =================================
omp_get_thread_num(): 3
Outer loop =================================
omp_get_thread_num(): 3
Outer loop =================================
omp_get_thread_num(): 3
Outer loop =================================
omp_get_thread_num(): 3
Outer loop =================================
omp_get_thread_num(): 3
Outer loop =================================
omp_get_thread_num(): 3
Outer loop =================================
omp_get_thread_num(): 3
Outer loop =================================
omp_get_thread_num(): 3
Outer loop =================================
omp_get_thread_num(): 3
Outer loop =================================
omp_get_thread_num(): 3
Outer loop =================================
omp_get_thread_num(): 3
Outer loop =================================
Outer loop =================================
omp_get_thread_num(): 1
Outer loop =================================
omp_get_thread_num(): 1
Outer loop =================================
omp_get_thread_num(): 1
Outer loop =================================
omp_get_thread_num(): 1
Outer loop =================================
omp_get_thread_num(): 1
Outer loop =================================
omp_get_thread_num(): 1
Outer loop =================================
omp_get_thread_num(): 1
Outer loop =================================
omp_get_thread_num(): 1
Outer loop =================================
omp_get_thread_num(): 1
Outer loop =================================
omp_get_thread_num(): 1
Outer loop =================================
omp_get_thread_num(): 1
Outer loop =================================
omp_get_thread_num(): 1
Outer loop =================================
omp_get_thread_num(): 1
Outer loop =================================
omp_get_thread_num(): 1
Outer loop =================================
omp_get_thread_num(): 1
Outer loop =================================
omp_get_thread_num(): 1
Outer loop =================================
omp_get_thread_num(): 1
Outer loop =================================
omp_get_thread_num(): 1
% of work done 19
Outer loop =================================
omp_get_thread_num(): 0
% of work done 54
Outer loop =================================
omp_get_thread_num(): 0
% of work done 55
Outer loop =================================
omp_get_thread_num(): 0
% of work done 56
Outer loop =================================
omp_get_thread_num(): 0
% of work done 57
Outer loop =================================
omp_get_thread_num(): 0
% of work done 58
Outer loop =================================
omp_get_thread_num(): 0
% of work done 59
Outer loop =================================
omp_get_thread_num(): 0
% of work done 60
Outer loop =================================
omp_get_thread_num(): 0
% of work done 61
Outer loop =================================
omp_get_thread_num(): 0
% of work done 62
Outer loop =================================
omp_get_thread_num(): 6
Outer loop =================================
omp_get_thread_num(): 6
Outer loop =================================
omp_get_thread_num(): 6
Outer loop =================================
omp_get_thread_num(): 6
Outer loop =================================
omp_get_thread_num(): 6
omp_get_thread_num(): 3
Outer loop =================================
omp_get_thread_num(): 3
Outer loop =================================
omp_get_thread_num(): 1
Outer loop =================================
omp_get_thread_num(): 5
Outer loop =================================
omp_get_thread_num(): 5
Outer loop =================================
omp_get_thread_num(): 5
Outer loop =================================
omp_get_thread_num(): 5
Outer loop =================================
omp_get_thread_num(): 5
Outer loop =================================
omp_get_thread_num(): 5
Outer loop =================================
omp_get_thread_num(): 5
Outer loop =================================
omp_get_thread_num(): 5
Outer loop =================================
Outer loop =================================
omp_get_thread_num(): 4
Outer loop =================================
omp_get_thread_num(): 4
Outer loop =================================
omp_get_thread_num(): 4
Outer loop =================================
omp_get_thread_num(): 4
Outer loop =================================
omp_get_thread_num(): 4
Outer loop =================================
omp_get_thread_num(): 4
Outer loop =================================
omp_get_thread_num(): 4
Outer loop =================================
omp_get_thread_num(): 4
Outer loop =================================
omp_get_thread_num(): 4
Outer loop =================================
omp_get_thread_num(): 4
omp_get_thread_num(): 7
Outer loop =================================
omp_get_thread_num(): 7
Outer loop =================================
omp_get_thread_num(): 7
Outer loop =================================
omp_get_thread_num(): 7
Outer loop =================================
omp_get_thread_num(): 7
Outer loop =================================
omp_get_thread_num(): 7
Outer loop =================================
omp_get_thread_num(): 2
Outer loop =================================
omp_get_thread_num(): 2
Outer loop =================================
omp_get_thread_num(): 2
Outer loop =================================
omp_get_thread_num(): 2
Outer loop =================================
omp_get_thread_num(): 2
Outer loop =================================
omp_get_thread_num(): 2
Outer loop =================================
omp_get_thread_num(): 2