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

fix an issue that ConsumeTasks() ends before all tasks consumed

Browse Source
This commit is contained in:
falsycat 2023-08-05 23:23:47 +09:00
parent 1319a81ce2
commit ca16c6948a
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
core/luajit/context_test.hh
View File

@ -125,10 +125,11 @@ class ContextFixture : public ::testing::TestWithParam<Context::Kind> {
}
void ConsumeTasks() noexcept {
SyncDriver sync_driver;
syncq_->Drive(sync_driver);
WaitAsyncTasks(std::chrono::seconds(1));
for (uint32_t i = 0; i < 16; ++i) {
SyncDriver sync_driver;
syncq_->Drive(sync_driver);
WaitAsyncTasks(std::chrono::seconds(1));
}
}
void WaitAsyncTasks(auto dur) noexcept {
if (!asyncq_->WaitForEmpty(dur)) {