当异步任务为另一个任务运行时，如何锁定列表？

问题描述

我有一个任务需要每1分钟运行一次。我希望我发送给此任务的订单列表中的订单不在下一个任务中，即使它尚未完成。我应该如何进行开发？

async_row_process = kwargs.get("async_row_process",True)
    #when next task is running task must leave prevIoUs 'prevIoUs order list'
    for order in orders:
        if async_row_process:
            row_method.delay(row=order,lock_name=lock_name,Now='%s' % Now,*args,**kwargs)

我应该开发一个装饰器吗？还是可以对所有任务使用订单队列？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）