现在我有一些大任务,所有这些任务都是由一些小任务组成的,我把它们放到一个代理中,当一个大任务的所有小任务完成后,我需要一个回调来处理这些小任务的结果 我知道芹菜有原始和弦,只要我有一个大任务就可以做,但我有很多 所以,如果我这样写:
chord([task11.s(),task12.s()])(mycallback.s()).get()
chord([task21.s(),task22.s()])(mycallback.s()).get()
第二条线要到第一条线结束才开始,但是这样的话,有些工人会长期成为偶像,这是不好的, 那么,芹菜中是否有某种方式可以在某些情况发生时回调,但不会阻止进程?在
===============================================
应用异步工程!@吉格帕默,谢谢你的帮助
尝试链接异步方法,以便当一个方法完成时,您可以使用apply_async调用链中的下一个方法,并使用所需的参数来创建一个新的作业(应该在不同的队列中)。在
相关问题 更多 >
编程相关推荐