@ -814,6 +814,11 @@ namespace {
size_t queueDepth = state->queue.pendingCount.load(std::memory_order_acquire);
if (queueDepth == 0U) {
std::this_thread::sleep_for(std::chrono::milliseconds(SQLITE_BATCH_WAIT_MS));
if (g_killed) {
delete th;
return nullptr;
}
continue;
Powered by TurnKey Linux.