python - 多处理和全局 True/False 变量

Question

我正在努力了解多处理并将全局 True/False 变量传递到我的函数中。

在 get_data() 完成后，我希望 analysis() 函数启动并处理数据，同时 fetch() 继续运行。我怎样才能使这项工作？时间差

import multiprocessing

ready = False


def fetch():
    global ready
    get_data()
    ready = True
    return


def analysis():
    analyse_data()

if __name__ == '__main__':
    p1 = multiprocessing.Process(target=fetch)
    p2 = multiprocessing.Process(target=analysis)
    p1.start()
    if ready:
        p2.start()

Answer 1

您应该运行这两个进程并使用共享队列在它们之间交换信息，例如在其中一个进程中发出操作完成信号。

此外，您需要有一个 join() 语句来正确等待您生成的进程完成。

from multiprocessing import Process, Queue
import time

def get_data(q):
  #Do something to get data
  time.sleep(2)
  #Put an event in the queue to signal that get_data has finished
  q.put('message from get_data to analyse_data')

def analyse_data(q):
  #waiting for get_data to finish...
  msg = q.get()
  print msg #Will print 'message from get_data to analyse_data'
  #get_data has finished

if __name__ == '__main__':
  #Create queue for exchanging messages between processes
  q = Queue()
  #Create processes, and send the shared queue to them
  processes = [Process(target=get_data,args(q,)),Process(target=analyse_data,args=(q,))]
  #Start processes
  for p in processes:
    p.start()
  #Wait until all processes complete
  for p in processes:
    p.join()