nf7/nf7
nf7/nf7
1
0
Fork 0
Code Issues 9 Pull Requests Projects 3 Releases 5 Wiki Activity

set maximum duration for waiting finish of tasks while exitting Nf7

Browse Source
This commit is contained in:
falsycat 2022-11-29 13:00:50 +09:00
parent 6e4f8aa114
commit 6ed9f7e463
1 changed files with 20 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
main.cc
View File

@ -580,16 +580,33 @@ int main(int, char**) {
}
{
bool gracefull_exit = false;
ZoneScopedN("wait for all tasks");
for (;;) {
for (size_t i = 0; i < 100;) {
{
ZoneScopedN("check remained tasks");
std::unique_lock<std::shared_mutex> sk {task_mtx_};
if (!mainq_.size() && !subq_.size() && !asyncq_.size() && !glq_.size()) {
if (mainq_.size() > 0) {
TracyMessageL("main task is remained");
} else if (!subq_.idle()) {
TracyMessageL("subq is not idle");
} else if (!asyncq_.idle()) {
TracyMessageL("asyncq is not idle");
} else if (!glq_.idle()) {
TracyMessageL("glq is not idle");
} else {
TracyMessageL("all tasks done");
gracefull_exit = true;
break;
}
}
std::this_thread::sleep_for(30ms);
std::this_thread::sleep_for(10ms);
}
if (!gracefull_exit) {
std::cout << "workers berserking, kills them all" << std::endl;
return EXIT_SUCCESS;
}
}