Method OnConsumeThreadRun

phxqueue/consumer/consumer.h:121–121

Callback after the consume thread start.

    // Callback after the consume thread start.
    virtual void OnConsumeThreadRun(const int vpid) {}

    // The processing flow of pull thread is as follows:
    // 1. Identify which queue to be handled by self.