如何在芹菜中回调但不阻塞进程

2024-10-02 00:41:50 发布

您现在位置:Python中文网/ 问答频道 /正文

现在我有一些大任务,所有这些任务都是由一些小任务组成的,我把它们放到一个代理中,当一个大任务的所有小任务完成后,我需要一个回调来处理这些小任务的结果 我知道芹菜有原始和弦,只要我有一个大任务就可以做,但我有很多 所以,如果我这样写:

chord([task11.s(),task12.s()])(mycallback.s()).get()
chord([task21.s(),task22.s()])(mycallback.s()).get()

第二条线要到第一条线结束才开始,但是这样的话,有些工人会长期成为偶像,这是不好的, 那么,芹菜中是否有某种方式可以在某些情况发生时回调,但不会阻止进程?在

===============================================

应用异步工程!@吉格帕默,谢谢你的帮助


Tags: 代理get进程方式情况工程芹菜工人
1条回答
网友
1楼 · 发布于 2024-10-02 00:41:50

尝试链接异步方法,以便当一个方法完成时,您可以使用apply_async调用链中的下一个方法,并使用所需的参数来创建一个新的作业(应该在不同的队列中)。在

相关问题 更多 >

    热门问题