Workflow extra

基于 promise 的一个流程管理小工具。

parallel

/**
 * 接收一个数据队列和一个 generate 函数, 通过将数据传递给 generate 拿到一个 promise 对象
 * 根据 num 传入的并行个数进行适当任务的并发
 * 
 * @param tasks[any[]]
 * @param generate[Function]
 * @param num[Number]
 */
export function parallel(tasks: any[], generate: Function, num = 1): Promise<any[]> {}

ParallelQueue

/**
 * 任务管理器，允许同时并发多个异步任务
 * 并且允许复用这个管理器，在允许过程中动态添加任务
 * 并提供等待任务队列结束的功能
 */
export class ParallelQueue<TaskObject, ReturnValue> {}