atomic-queue:持久队列状态并可以重新启动的崩溃友好队列。 使用工作池并具有可配置的并发

原子队列 持久队列状态并可以重新启动的崩溃友好队列。 使用工作池并具有可配置的并发 原料药 有关用法示例，请参见test.js var queue = require('atomic-queue')(worker, opts) 使用worker函数和可选选项初始化新队列。 queue是流 您可以通过将它们写入队列流来对它们进行排队： queue . write ( 'hello' ) queue . write ( 'goodbye' ) queue . write ( { name : 'bob' } ) worker必须是具有以下API的函数： function work ( data , done ) { // do work, then call done with (err) if there was an error } data在工人功能将是你写入队列上面的