We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 9e64fcf commit e551bf8Copy full SHA for e551bf8
library.cpp
@@ -276,21 +276,14 @@ extern "C"
276
}
277
278
size_t lastProcessed = 0;
279
- while (true) {
280
- bool allDone = true;
281
- for (auto& t : threads) {
282
- if (t.joinable()) {
283
- allDone = false;
284
- break;
285
- }
286
287
-
288
- if (allDone)
289
290
+ bool cancelLogged = false;
+ while (processedFunctions.load() < totalFuncs) {
291
if (task->IsCancelled()) {
292
shouldCancel.store(true);
293
- LogWarn("Cancelling operation...");
+ if (!cancelLogged) {
+ LogWarn("Cancelling operation...");
+ cancelLogged = true;
+ }
294
295
296
size_t currentProcessed = processedFunctions.load();
0 commit comments