如果任务处理失败，怎么结束所有任务

[xiaoyaos]

如果任务处理失败，怎么结束所有任务

[xiaoyaos]

比如说一共100个任务都push进去了，第10个任务失败了，需要结束所有任务，怎么让bagepipe手动停止下来呢？

[xiaoyaos]

我修改了源码148行：method.apply(null, args)->method.apply(this, args),将this对象向外抛出，然后在回调中修改limit参数为0， queue=[]，使之后面的任务不在继续，目前还有一个问题就是，修改后，还会继续执行一轮任务，因为业务的关系，我先这样使用，期盼有其他更好的方法的朋友能给给出指正，谢谢！

[lilifan]

你可以改源码实现，还需要的话我帮你改下吧 @xiaoyaos

[lilifan]

@xiaoyaos https://github.com/JacksonTian/bagpipe/pull/27 可以看下我这个mr