python - 让 Python 等待函数完成后再继续执行程序

Question

我有一个我编写的Python程序。这个 python 程序调用我也编写的模块中的一个函数，并向其传递一些数据。

程序:

def Response(Response):
    Resp = Response
def main():
   myModule.process_this("hello") #Send string to myModule Process_this function
   #Should wait around here for Resp to contain the Response
   print Resp

该函数对其进行处理并将其作为响应传回主程序中的 Response 函数。

我的模块:

def process_this(data)
    #process data
    program.Response(data)

我检查过，所有数据都正确传递。我省略了所有导入和数据处理，以使这个问题尽可能简洁。

我需要找到某种方法让 Python 等待 resp 实际包含响应，然后再继续执行程序。我一直在寻找线程和使用信号量或使用队列模块，但我不是 100% 确定如何将它们合并到我的程序中。

Answer 1

这是一个使用队列和线程模块的可行解决方案。注意:如果您的任务受 CPU 限制而不是 IO 限制，则应使用 multiprocessing相反

import threading
import Queue

def worker(in_q, out_q):
    """ threadsafe worker """
    abort = False
    while not abort:
        try:
            # make sure we don't wait forever
            task = in_q.get(True, .5)
        except Queue.Empty:
            abort = True
        else:
            # process task
            response = task
            # return result 
            out_q.put(response)
            in_q.task_done()
# one queue to pass tasks, one to get results
task_q = Queue.Queue()
result_q = Queue.Queue()
# start threads
t = threading.Thread(target=worker, args=(task_q, result_q))
t.start()
# submit some work
task_q.put("hello")
# wait for results
task_q.join()
print "result", result_q.get()