-
Notifications
You must be signed in to change notification settings - Fork 2.5k
Open
Description
ParallelWork *pwork = Workflow::create_parallel_work(_parallel_work_callback);
pwork->set_context(context);
WFGoTask *task = WFTaskFactory::create_go_task("mysql", db_create, db_data, std::ref(context->db_flag), true);
task->set_callback([](WFGoTask *task)
{ log_debug_g("set user_session in db , done \n"); });
业务历史原因,改造时 使用go_task 替代异步的 mysql 操作,但是发现调度花费较长时间 (在db_create 中,打点,函数执行的很快),进入并行任务的回调耗时很长。
Metadata
Metadata
Assignees
Labels
No labels