Class BThreadQueue

src/query/executor/bthread_queue.h:34–79

! * Implementation of TaskQueue interface, which based on Execution * Queue in brpc */

 * Queue in brpc
 */
class BThreadQueue : public TaskQueue {
 public:
  //! Disable copy and assigment operator on BThreadQueue instance
  // DISALLOW_COPY_AND_ASSIGN(BThreadQueue);

  //! Constructor
  BThreadQueue();

  //! Destructor
  ~BThreadQueue() override;

 public:
  //! Retrieve id of queue
  uint64_t id() const;

  //! Start task queue, return value 0 for success, otherwise failed
  int start() override;

  //! Stop task queue, return value 0 for success, otherwise failed
  int stop() override;

  //! Join task queue, return value 0 for success, otherwise failed
  int join() override;

  //! Put the task in queue
  //! @return,     0: succeed, mark status of task as Scheduled
  //!          other: failed
  int put(const TaskPtr &task) override;

  //! Retrieve start flags
  bool started() const override;

 private:
  //! Release all resourced
  void clear_context();

 private:
  //! Identifier of execution queue
  bthread::ExecutionQueueId<TaskPtr> queue_id_ = {0};

  //! Default options for execution queue
  bthread::ExecutionQueueOptions options_{};

  //! Queue status
  TaskQueue::Status status_{TaskQueue::Status::INITIALIZED};
};


}  // namespace query