Function tutorial_message_pub_sub

tutorial/T17-MessagePubSub.cpp:46–60

void tutorial_message_pub_sub() {
    // 一个pipeline pub数据，其他pipeline sub相同的数据内容
    std::thread pubThd = std::thread(pub_message);
    std::thread subThd1 = std::thread(sub_message);
    std::thread subThd2 = std::thread(sub_message);
    std::thread subThd3 = std::thread(sub_message);

    pubThd.join();
    subThd1.join();
    subThd2.join();
    subThd3.join();

    CGRAPH_CLEAR_MESSAGES()
    GPipelineFactory::clear();
}


int main() {