Method getQueueManager

src/Interpreters/Context.cpp:1028–1034

}

QueueManagerPtr Context::getQueueManager() const
{
    auto lock = getLock(); // checked
    if (!shared->queue_manager)
        shared->queue_manager = std::make_shared<QueueManager>(global_context);
    return shared->queue_manager;
}

AsyncQueryManagerPtr Context::getAsyncQueryManager() const
{