问题描述
我有一个内核很少的 iPyParallel 集群。我已经通过 apply_async() 向他们提交了不同的任务。它们中的大多数已完成,并且 AsyncResult.ready() 正确显示了状态。但是有一个很长的运行时间,我想在特定时间后从客户端代码中止/终止它。
ippCluster.outstanding
显示未完成的任务。
ippCluster.abort("5baf4b1e-c47a639daa7ca9db08a01d0b")
提示:<Future at 0x1f296b70fc8 state=pending>
ippCluster.shutdown("all")
关闭所有“空闲”引擎,但直到运行的引擎。
但它也会关闭我想用于进一步计算的内核/引擎,所以这不是我想要的。
如果,即任务内部有一个无限循环,那么如何远程终止这个任务?
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)