Skip to content

Commit 321b487

Browse files
committed
Adding print statements inside parallel for
1 parent 2102dda commit 321b487

1 file changed

Lines changed: 14 additions & 2 deletions

File tree

src/cgi/core_genome_identity.cpp

Lines changed: 14 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -54,9 +54,12 @@ int main(int argc, char** argv)
5454
//Final output vector of ANI computation
5555
std::vector<cgi::CGI_Results> finalResults;
5656

57-
#pragma omp parallel for
57+
#pragma omp parallel for schedule(static,1)
5858
for (uint64_t i = 0; i < parameters.threads; i++)
5959
{
60+
if ( omp_get_thread_num() == 0)
61+
std::cerr << "INFO [thread 0], skch::main, Count of threads executing parallel_for : " << omp_get_num_threads() << std::endl;
62+
6063
//start timer
6164
auto t0 = skch::Time::now();
6265

@@ -100,9 +103,18 @@ int main(int argc, char** argv)
100103
cgi::correctRefGenomeIds (finalResults_local);
101104

102105
#pragma omp critical
103-
finalResults.insert (finalResults.end(), finalResults_local.begin(), finalResults_local.end());
106+
{
107+
finalResults.insert (finalResults.end(), finalResults_local.begin(), finalResults_local.end());
108+
}
109+
110+
#pragma omp critical
111+
{
112+
std::cerr << "INFO [thread " << omp_get_thread_num() << "], skch::main, ready to exit the loop" << std::endl;
113+
}
104114
}
105115

116+
std::cerr << "INFO, skch::main, parallel_for execution finished" << std::endl;
117+
106118
//report output in file
107119
cgi::outputCGI (parameters, finalResults, fileName);
108120

0 commit comments

Comments
 (0)