Method GetThreadInstance

phxqueue/comm/breakpoint.cpp:23–34

ConsumerBP *ConsumerBP::GetThreadInstance() {
    static thread_local ConsumerBP *bp{nullptr};
    if (!bp) {
        bp = plugin::BreakPointFactory::GetInstance()->NewConsumerBP().release();
    }
    if (!bp) {
        bp = new ConsumerBP();
    }
    assert(bp);

    return bp;
}

ConsumerConsumeBP *ConsumerConsumeBP::GetThreadInstance() {
    static thread_local ConsumerConsumeBP *bp{nullptr};