日志模块内部 - 工作流程图
2022-02-11 11:58:46 0 举报日志模块工作流程图
作者其他创作
大纲/内容
否
退出
创建并启动内部工作线程
GetPlayerLog()
创建点播相关处理器
初始化开始
创建直播相关处理器
数据消费
是
Release()
挑选数据
从未处理容器(UnProcessed Container)中移除
是否有新事件到来？
事件收集
External Thread1 (日志模块初始化调用线程)
组织成点播需要的数据字典，并返回
External Thread3 (SDK Get Log)
释放开始
调用消费者模块的获取日志接口
存入处理过的容器(Processed Container)
轮训处理器执行处理工作
停止结束
轮训消费者执行数据消费工作
创建点播日志消费者
释放处理器/调度器/消费者
创建直播日志消费者，并挂载到工作流中
External Thread2 (Publisher OnNorify)
线程退出
Stop()
OnNotify()
数据处理(依次将事件送入处理器)
停止开始
点播/直播的end获取
订阅所有日志模块关注的事件
启动
Start()
Internal Thread1 (Worker)
事件合并
存入未处理事件容器
释放结束
数据消费(依次将事件送入消费者模块)
Loop开始
数据处理
Init()
点播？
组织成直播需要的JSON串，并返回
Sleep(300ms)
创建调度池，并绑定到处理器调度池中
停止并等待工作线程退出
收藏
收藏
0 条评论
下一页
