RT：小弟这边为了保证某 task 优先运行完成，采用了检查结果返回状态的法子：
while not result.ready():
比如下面的样例代码，任务没有 ready 就一直循环（ PS：用 result.get 也会出现类似的情况）：
from tasks import add
result = add.delay(4, 4) #不要直接 add(4, 4)，这里需要用 celery 提供的接口 delay 进行调用
while not result.ready():
time.sleep(1)
print 'task done: {0}'.format(result.get())
结果小弟发现那个需要优先运行的任务，就一直处在 received 的状态，result.ready()的返回一直是 False。 此前以为 task 函数的原因，检查了并没有发现问题。
很急，在线求大神解答为啥会出现这种情况。 感谢！
 |
1
NaVient May 17, 2017
while True:
|
|
2
NaVient May 17, 2017
while True:
if result.ready(): break 这样才是循环,你那个一开始任务是 false,循环都进不去 |
 |
3
akmonde OP @NaVient
result.ready()结果开始就是 False 啊，循环是进去了的，time.sleep(1)会一直下去，这个我试过打印内容印证过的。 但我要做的那个任务始终在 PENDING，或者说是 RECEIVED 状态，并没有开始做，不用循环，直接 result.ready()是可以运行那个任务的，但是却没有锁住的效果了。 |
 |
4
r0okit May 17, 2017
这段代码就是例子代码，没问题，请教别人的时候给出详细的信息，用的是 redis 还是 rabbitmq，配置贴上來
|
|
5
akmonde OP @r0okit
首先感谢这位朋友，贴下 redis 的配置如下： celery = Celery('achrief', backend='redis://localhost:6379/0', broker='redis://localhost:6379/0') 我这边仔细比较过，真实代码跟样例情况是一模一样的，换了变量和函数名而已，这里就不贴了。 另外，celery 配置文件里添加了以下内容，不过并没有起作用： CELERY_IGNORE_RESULT=False 另外，我这边是 Linux 环境，有朋友说的 win 下运行可以加-p threads 或者啥 pool 参数的我也试过了，没有起作用。 |
 |
6
zsz May 17, 2017 via iPhone
celery server 运行起来了么？
|
|
8
akmonde OP @r0okit
我那边单独测了上面提到的 demo 代码，是可用的。 但我这边是同时运行了多个任务，其中夹杂了这个优先级高的任务，就会出问题了，代码如下： if item in match_items: result = eval(item).delay(x,y) result_list.append(eval_result) else: eval(item).delay(x,y) for result_item in result_list: while not result_item.ready(): time.sleep(2) 然后那个任务会一直在 PENDING，或者说是 RECEIVED 状态，并没有启动，一直 sleep。 |
|
9
zsz May 18, 2017 via iPhone
其他任务都不是 delay 执行的吧？
|
 |
12
pkking May 18, 2017
你这个逻辑是不是应该用 chain 或者 callback ？
|
|
13
akmonde OP @r0okit eval 是为了把前端传过来的字符串，作为函数名执行哈，咱们可以把它这样等价：
eval(item).delay(x,y) == add.delay(x,y) 另外，确实这段代码是放在一个任务函数里去调用的，用不用 delay 都出现了这种情况。 |
|
15
zsz May 18, 2017 via iPhone
@akmonde
加我们的群问效率高些，一群工程师组建的面向初学者的 Python Linux 学习群，qq 群号：278529278， Php Linux 学习群，qq 群号：476648701， 非商业性质，拒绝广告，只接收真正想学这方面技术的朋友，交流学习，申请请说明来自 v2ex |
|
16
r0okit May 19, 2017
|
|
17
akmonde OP @r0okit eval 之前已经对能执行恶意命令的特殊字符进行了过滤，也不涉及库查询，所以应该不会有安全方面的问题。
我去研究下 chain 和怎么用字典名字映射函数，先谢谢您。 这问题也是够折腾的，这两天在一步步替换正常的配置和代码进行对比，真是头疼，问题出现的有点隐蔽。 |
|
19
akmonde OP |
|
20
akmonde OP @r0okit @pkking
两位大牛，不好意思再次打扰一下。 我这边看了下，我前端 flower 通过参数传过来，进行程序启动的那个函数，肯定是需要 delay 的，调用方式就下面两种： http://flower-docs-cn.readthedocs.io/zh/latest/api.html#post-api-task-async-apply http://flower-docs-cn.readthedocs.io/zh/latest/api.html#post-api-task-send-task 那么问题来了，我看了下案例： http://celery.readthedocs.io/en/latest/userguide/tasks.html#avoid-launching-synchronous-subtasks 这里调用 chain 是不能使用 delay 的函数的，好像是需要在一个普通函数或者在程序主体里去调用 chain 的。 那么在程序入口需要在 delay 的函数里的情况下，我应该如何去使用 chain 呢？这好像是个悖论，没想明白应该怎么弄。 |
Select Language