queue是一个串行的消息队列,通过限制了worker数量,不再一次性全部执行。当worker数量不够用时,新加入的任务将会排队等候,直到有新的worker可用。该函数有多个点可供回调,如worker用完时、无等候任务时、全部执行完时等。
queue(worker, concurrency)
工具函数:
代码示例:
创建queue实例:
监听:
推送任务:
结果:
同时加入多个任务:
结果:
queue是一个串行的消息队列,通过限制了worker数量,不再一次性全部执行。当worker数量不够用时,新加入的任务将会排队等候,直到有新的worker可用。该函数有多个点可供回调,如worker用完时、无等候任务时、全部执行完时等。
queue(worker, concurrency)
工具函数:
代码示例:
创建queue实例:
监听:
推送任务:
结果:
同时加入多个任务:
结果: