in rela/batch_runner.h [46:60]
void start() {
if (batchers_.empty()) {
for (auto& name : methods_) {
batchers_.emplace(name, std::make_unique<Batcher>(batchsize_));
}
} else {
for (auto& kv : batchers_) {
kv.second->reset();
}
}
for (auto& kv : batchers_) {
threads_.emplace_back(&BatchRunner::runnerLoop, this, kv.first);
}
}