Method ThreadPoolSingleton

src/librbd/Journal.cc:53–60

  ContextWQ *work_queue;

  explicit ThreadPoolSingleton(CephContext *cct)
    : ThreadPool(cct, "librbd::Journal", "tp_librbd_journ", 1),
      work_queue(new ContextWQ("librbd::journal::work_queue",
                               ceph::make_timespan(
                                 cct->_conf.get_val<uint64_t>("rbd_op_thread_timeout")),
                               this)) {
    start();
  }
  ~ThreadPoolSingleton() override {
    work_queue->drain();
    delete work_queue;