Class PluckThread

phxrpc/rpc/test_thread_queue.cpp:34–67

class PluckThread {
  public:
    PluckThread(ThdQueue<int> * thd_queue, const size_t thread_count) :
    thd_queue_(thd_queue) {
        for (size_t i = 0; i < thread_count; i++) {
            thread * thd = new thread(&PluckThread::Func, this, i);
            thread_list_.push_back(thd);
        }
    }

    ~PluckThread() {
        thd_queue_->break_out();
        for (auto & thd : thread_list_) {
            thd->join();
            delete thd;
        }
    }

    void Func(size_t id) {
        int n = 0;
        do {
            bool succ = thd_queue_->pluck(n);
            if (succ) {
                printf("thread_id(%zu) value(%d)\n", id, n);
            } else {
                break;
            }
        } while (!thd_queue_->empty());
    }

  private:
    ThdQueue<int> * thd_queue_;
    vector<thread *> thread_list_;
};

int main(int argc, char ** argv) {
    ThdQueue<int> thd_queue;