Zengtudor/ccls
1
0
Fork 0
mirror of https://github.com/MaskRay/ccls.git synced 2024-11-22 07:35:08 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

sema_manager: only keep latest session.maxNum sessions in case of a surge of textDocument/didChange

Browse Source
This commit is contained in:
Fangrui Song 2021-09-23 14:41:51 -07:00
parent 3ce756e39a
commit 5a48e6c419
2 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/sema_manager.cc
View File

@ -421,7 +421,8 @@ void *preambleMain(void *manager_) {
auto *manager = static_cast<SemaManager *>(manager_); auto *manager = static_cast<SemaManager *>(manager_);
set_thread_name("preamble"); set_thread_name("preamble");
while (true) { while (true) {
SemaManager::PreambleTask task = manager->preamble_tasks.dequeue(); SemaManager::PreambleTask task = manager->preamble_tasks.dequeue(
g_config ? g_config->session.maxNum : 0);
if (pipeline::g_quit.load(std::memory_order_relaxed)) if (pipeline::g_quit.load(std::memory_order_relaxed))
break; break;

4
src/threaded_queue.hh
View File

@ -126,12 +126,14 @@ public:
bool isEmpty() { return total_count_ == 0; } bool isEmpty() { return total_count_ == 0; }
// Get the first element from the queue. Blocks until one is available. // Get the first element from the queue. Blocks until one is available.
T dequeue() { T dequeue(int keep_only_latest = 0) {
std::unique_lock<std::mutex> lock(mutex_); std::unique_lock<std::mutex> lock(mutex_);
waiter_->cv.wait(lock, waiter_->cv.wait(lock,
[&]() { return !priority_.empty() || !queue_.empty(); }); [&]() { return !priority_.empty() || !queue_.empty(); });
auto execute = [&](std::deque<T> *q) { auto execute = [&](std::deque<T> *q) {
if (keep_only_latest > 0 && q->size() > keep_only_latest)
q->erase(q->begin(), q->end() - keep_only_latest);
auto val = std::move(q->front()); auto val = std::move(q->front());
q->pop_front(); q->pop_front();
--total_count_; --total_count_;