summaryrefslogtreecommitdiff
path: root/graphics/asymptote/LspCpp/LibLsp/JsonRpc/threaded_queue.cpp
blob: 17e965eadf18d646154fdb221350fc496c81d175 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
#include "threaded_queue.h"

// static
bool MultiQueueWaiter::HasState(
    std::initializer_list<BaseThreadQueue*> queues) {
  for (BaseThreadQueue* queue : queues) {
    if (!queue->IsEmpty())
      return true;
  }
  return false;
}

bool MultiQueueWaiter::ValidateWaiter(
    std::initializer_list<BaseThreadQueue*> queues) {
  for (BaseThreadQueue* queue : queues) {
    if (queue->waiter.get() != this)
      return false;
  }
  return true;
}