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

fix nf7::Thread wasting SyncWorker

Browse Source
This commit is contained in:
falsycat 2022-11-20 14:15:07 +09:00
parent 0c29b828c4
commit 4f94ea4e3b
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
common/thread.hh
View File

@ -57,6 +57,7 @@ class Thread final : public nf7::Context,
std::mutex mtx_; std::mutex mtx_;
bool working_ = false; bool working_ = false;
nf7::Env::Time scheduled_;
std::atomic<size_t> tasks_done_ = 0; std::atomic<size_t> tasks_done_ = 0;
@ -81,11 +82,12 @@ class Thread final : public nf7::Context,
{ {
std::unique_lock<std::mutex> k {mtx_}; std::unique_lock<std::mutex> k {mtx_};
if (auto time = q_.next()) { if (auto time = q_.next()) {
working_ = false; if (time <= nf7::Env::Clock::now() || time != scheduled_) {
env().Exec(exec_, self, [this]() mutable { ExecNext(); }, *time); scheduled_ = *time;
} else { env().Exec(exec_, self, [this]() mutable { ExecNext(); }, *time);
working_ = false; }
} }
working_ = false;
} }
} }
}; };