fixed thread id

muellan · muellan · commit 50dbe3bc29cf · 2018-09-12T14:39:46.000+02:00
diff --git a/src/querying.h b/src/querying.h
@@ -99,9 +99,8 @@ void query_batched(
 
     std::vector<std::thread> threads;
     // assign work to threads
-    for(int i = 0; i < opt.numThreads; ++i) {
-        threads.emplace_back([&] {
-            const int threadId = i;
+    for(int threadId = 0; threadId < opt.numThreads; ++threadId) {
+        threads.emplace_back([&,threadId] {
             try {
                 sequence_pair_reader reader{filename1, filename2};
 
@@ -182,7 +181,7 @@ void query_batched(
                 }
             }
             catch(file_access_error& e) {
-                if(threadId == 1) {
+                if(threadId == 0) {
                     std::lock_guard<std::mutex> lock(exceptionMtx);
                     log(std::string("FAIL: ") + e.what());
                 }

Original file line number	Diff line number	Diff line change
`@@ -99,9 +99,8 @@ void query_batched(`
`99`	`99`
`100`	`100`	`std::vector<std::thread> threads;`
`101`	`101`	`// assign work to threads`
`102`		`- for(int i = 0; i < opt.numThreads; ++i) {`
`103`		`- threads.emplace_back([&] {`
`104`		`- const int threadId = i;`
	`102`	`+ for(int threadId = 0; threadId < opt.numThreads; ++threadId) {`
	`103`	`+ threads.emplace_back([&,threadId] {`
`105`	`104`	`try {`
`106`	`105`	`sequence_pair_reader reader{filename1, filename2};`
`107`	`106`
`@@ -182,7 +181,7 @@ void query_batched(`
`182`	`181`	`}`
`183`	`182`	`}`
`184`	`183`	`catch(file_access_error& e) {`
`185`		`- if(threadId == 1) {`
	`184`	`+ if(threadId == 0) {`
`186`	`185`	`std::lock_guard<std::mutex> lock(exceptionMtx);`
`187`	`186`	`log(std::string("FAIL: ") + e.what());`
`188`	`187`	`}`