Method run

example/E03-ThirdFlow.cpp:38–48

class InputGNode : public GNode {
public:
    CStatus run() override {
        for (int i = 0; i < 30; i++) {
            std::shared_ptr<InputMParam> input(new InputMParam());
            randomSleep(1, 5);    // 间隔1~6ms，发送一次
            input->num_ = std::abs((int)std::random_device{}()) % 5 + 1;
            CGRAPH_SEND_MPARAM(InputMParam, INPUT_TOPIC_NAME, input, GMessagePushStrategy::WAIT);
        }

        CGRAPH_ECHO("    ----> InputGNode run finished");
        return CStatus();
    }
};

class ProcessGNode : public GNode {