流式处理因子计算的时候，怎么做到并行计算因子

Question

关于因子计算 假定我要计算100个因子 每个因子耗时10毫秒 加起来就耗时1秒 这种情况怎么设计才能减少总的时间? 应用场景是接收行情、写入streamTable、计算因子、下发因子数据，怎么实现比较好？

Answer 1

可以用DolphinDB database中并行处理的高价函数，如ploop, peach, pcall等。
针对应用场景，可以每个因子做成一个函数。在message handler内部调用因子函数。