Function tutorial_message_send_recv

tutorial/T16-MessageSendRecv.cpp:42–52

void tutorial_message_send_recv() {
    CGRAPH_CREATE_MESSAGE_TOPIC(MyMessageParam, "send-recv", 48)    // 创建一个topic，也可以在算子中进行创建

    std::thread sendThd = std::thread(send_message);
    std::thread recvThd = std::thread(recv_message);
    sendThd.join();
    recvThd.join();

    CGRAPH_CLEAR_MESSAGES();
    GPipelineFactory::clear();
}


int main() {