呼叫并等待（一会儿）的异步事件在Python

Question

我想：

1. 启动异步任务（类似Django的芹菜或GEVENT）
2. 等待有限的时间量任务完成（1秒），
3. 然后继续不杀任务。

我注意到这个相关线程https://stackoverflow.com/a/13001153/226800;然而，在接受的答案中，当'g'被破坏时，任务是否也会被破坏？即使在任务的创建者已经返回后，我仍然希望允许任务在后台运行，等待一段时间后。

Answer 1

编辑：是的，如果你调用g.kill()，任务“载”由g也尽快杀死（即在第一个合作上下文切换）......，嗯，那是种了点，如果你想一想。

在GEVENT，这是你会怎么做：

import gevent 

def task(): 
    for _ in range(10): 
     print "processing" 
     gevent.sleep(1.0) 
    return 'result' 

task_g = gevent.spawn(task) 
res = task_g.join(timeout=3.0) 
if res is None: 
    print "task timed out but is continuing" 
else: 
    print "got result: ", res 

如果你而喜欢一个异常基于流的，你可以使用with_timeout;这也有个好处，你可以从你的任务返回None，并没有它混淆超时：

import gevent 
from gevent.timeout import Timeout, with_timeout 

def task(): 
    ... 

task_g = gevent.spawn(task) 

try: 
    result = with_timeout(3.0, task_g.join) 
except Timeout: 
    print "timeout" 
    result = None 
else: 
    print "got result:", result 

以后你仍然可以杀死的任务，如果出由task_g.kill()它“完全”时代。