使此代码非阻塞

Question

我正在使用 VSphere API，以下是我正在处理的行：

    task = vm.PowerOff()
    while task.info.state not in [vim.TaskInfo.State.success, vim.TaskInfo.State.error]:
        time.sleep(1)
        log.info("task {} is running".format(task))
    log.ingo("task {} is done".format(task))

这里的问题是，这会在任务未完成时完全阻止执行。我希望日志记录部分“并行”运行，这样我就可以开始其他任务了。

我想过创建一个函数，它可以接受一个任务作为参数，并像现在一样轮询info.state 属性，但是我如何使它成为非阻塞的呢？

编辑：我使用的是 Python 2.7

Answer 1

您可以使用asyncio 并创建一个事件循环。您可以使用asyncio.async() 创建一个不会阻塞事件循环执行的异步任务。

Answer 2

这里是一个使用线程模块的例子：

import threading

class VMShutdownThread(threading.Thread):
    def __init__(self, vm):
        self.vm = vm
    def run(self):
        task = vm.PowerOff()
        while task.info.state not in [vim.TaskInfo.State.success, vim.TaskInfo.State.error]:
            time.sleep(1)
            log.info("task {} is running".format(task))
        log.info("task {} is done".format(task))

vm_shutdown_thread = VMShutdownThread(vm)

vm_shutdown_thread.start() 

如果你创建了logger，你可以配置它来打印线程名。