Method run

example/E03-ThirdFlow.cpp:53–77

class ProcessGNode : public GNode {
public:
    CStatus run() override {
        while (true) {
            std::shared_ptr<InputMParam> input = nullptr;
            auto status = CGRAPH_RECV_MPARAM_WITH_TIMEOUT(InputMParam, INPUT_TOPIC_NAME, input, 1000);
            if (status.isErr()) {
                break;    // 一阵子收不到消息了，就自动停止好了
            }

            int ms = randomSleep(1, 100);    // 模拟处理流程，随机休息不超过 100ms
            std::shared_ptr<ResultMParam> result(new ResultMParam);
            switch (input->num_) {
                case 1: result->eng_info_ = "one"; break;
                case 2: result->eng_info_ = "two"; break;
                case 3: result->eng_info_ = "three"; break;
                default: result->eng_info_ = "other";
            }
            result->negative_num_ = -1 * input->num_;
            result->process_ts_ = ms;

            CGRAPH_SEND_MPARAM(ResultMParam, RESULT_TOPIC_NAME, result, GMessagePushStrategy::WAIT);
        }

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