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 8e58c43 commit 7345669Copy full SHA for 7345669
src/geode/basic/database.cpp
@@ -62,13 +62,14 @@ namespace geode
62
Logger::debug( count_, " -> ", "~Storage" );
63
terminate_storage();
64
std::unique_lock< std::mutex > locking{ lock_ };
65
- while( !queue_.empty() )
+ do
66
{
67
- Logger::debug( count_, " -> ", "Q ", queue_.size() );
68
clean_queue();
69
- Logger::debug( count_, " -> ", "Q2 ", queue_.size() );
70
- condition_.wait( locking );
71
- }
+
+ } while( !condition_.wait_for(
+ locking, std::chrono::milliseconds( 1 ), [this] {
+ return queue_.empty();
72
+ } ) );
73
Logger::debug( count_, " -> ", "~Storage end" );
74
}
75
0 commit comments