cargo也是一个串行的消息队列,类似于queue,通过限制了worker数量,不再一次性全部执行。当worker数量不够用时,新加入的任务将会排队等候,直到有新的worker可用。 cargo的不同之处在于,cargo每次会加载满额的任务做为任务单元,只有任务单元中全部执行完成后,才会加载新的任务单元。
cargo(worker, [payload])
代码示例:
创建cargo实例:
监听:
增加新任务:
结果:
cargo也是一个串行的消息队列,类似于queue,通过限制了worker数量,不再一次性全部执行。当worker数量不够用时,新加入的任务将会排队等候,直到有新的worker可用。 cargo的不同之处在于,cargo每次会加载满额的任务做为任务单元,只有任务单元中全部执行完成后,才会加载新的任务单元。
cargo(worker, [payload])
代码示例:
创建cargo实例:
监听:
增加新任务:
结果: