python – 如何判断AsyncResult是否永远不会准备好？

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了python – 如何判断AsyncResult是否永远不会准备好？，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1258字，纯文字阅读大概需要2分钟。

内容图文

场景 – 我有一个我正在完成任务的进程池.但是,如果在运行任务时终止了子进程,则AsyncResult对象永远不会被标记为就绪.我希望会发生的是它会被标记为准备好并且不成功.

要重现这个：

>>> import multiprocessing
>>> import time
>>> p = multiprocessing.Pool(processes=1)
>>> result = p.apply_async(time.sleep, args=(1000,))
>>> result.ready()
False

在另一个shell中,找到进程ID并将其终止.

>>> result.ready()
False
>>> result.wait(5) # Waits 5 seconds even though subprocess is dead

这是一个问题,因为我有一个线程在等待工作完成,它通常有一个相当长的超时.如何在不需要等待超时的情况下完成result.wait(timeout)调用？另外,我怎么知道它已被放弃,而不仅仅是任务仍在运行但是我们达到了超时？

解决方法:

如果进程意外死亡,Pebble库会通知您.它还支持超时和回调.

这是你的榜样.

from pebble import ProcessPool
from concurrent.futures import TimeoutError

with ProcessPool() as pool:
    future = pool.schedule(time.sleep, args=(1000,), timeout=100)

    try:
        results = future.result()
        print(results)
    except TimeoutError as error:
        print("Function took longer than %d seconds" % error.args[1])
    except ProcessExpired as error:
        print("%s. Exit code: %d" % (error, error.exitcode))
    except Exception as error:
        print("function raised %s" % error)
        print(error.traceback)  # Python's traceback of remote process

documentation中有更多例子.

内容总结

以上是互联网集市为您收集整理的python – 如何判断AsyncResult是否永远不会准备好？全部内容，希望文章能够帮你解决python – 如何判断AsyncResult是否永远不会准备好？所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端