| 39 | void operator=(CompletionQueuePool const&) = delete; |
| 40 | |
| 41 | grpc::CompletionQueue *NextCompletionQueue() { |
| 42 | std::lock_guard<std::mutex> lock(mu_); |
| 43 | return threads_[next_round_robin_assignment_++ % |
| 44 | threads_.size()].completion_queue(); |
| 45 | } |
| 46 | |
| 47 | private: |
| 48 | explicit CompletionQueuePool(size_t thread_count) |
no test coverage detected