运行结果

Python多进程调用示例

import multiprocessing
import time
import os
import sys# 注册多个函数用于不同进程分别调用
def testcase0():time.sleep(1)return "case0_"+get_time()def testcase1(timestamp):return "case1_"+timestampdef testcase2(timestamp):return "case2_"+timestampdef testcase3(timestamp):print(timestamp)return# 初始化各进程函数
generate_func = testcase0
gather_func = testcase1
process_func = testcase2
show_func = testcase3#generate_func = None
#gather_func = None
#process_func = None
#show_func = None# 暂时无用
def proc_init(_generate, _gather, _process, _show):global generate_funcglobal gather_funcglobal process_funcglobal show_funcgenerate_func = _generategather_func = _gatherprocess_func = _processshow_func = _showreturn# 处理数据源
def generate_info(qdatain: multiprocessing.Queue):while True:if generate_func == None:time.sleep(1)continueqdatain.put(generate_func())print_time()return# 数据采集
def gather_info(qdatain: multiprocessing.Queue, qdataout: multiprocessing.Queue):while True:if gather_func == None:time.sleep(1)continueqdataout.put(gather_func(qdatain.get()))print_time()return# 数据处理
def process_info(qdatain: multiprocessing.Queue, qdataout: multiprocessing.Queue):while True:if process_func == None:time.sleep(1)continueqdataout.put(process_func(qdatain.get()))print_time()return# 数据展示
def show_info(qdatain: multiprocessing.Queue):while True:if show_func == None:time.sleep(1)continueshow_func(qdatain.get())print_time()returndef get_time():timestamp = time.strftime('%Y_%m_%d_%H_%M_%S', time.localtime(time.time()))return timestampdef print_time():print(get_time())return# 方便打包到EXE使用
def main():print(__file__)print_time()qdatain = multiprocessing.Queue()qdataout = multiprocessing.Queue()qdatashow = multiprocessing.Queue()proclist = []proclist.append(multiprocessing.Process(target=generate_info, args=(qdatain,)))proclist.append(multiprocessing.Process(target=gather_info, args=(qdatain, qdataout,)))proclist.append(multiprocessing.Process(target=process_info, args=(qdataout, qdatashow,)))proclist.append(multiprocessing.Process(target=show_info, args=(qdatashow,)))for k in proclist:k.start()while True:print_time()time.sleep(10)return# 外部调用主函数
if __name__ == "__main__":# 全局变量无效果multiprocessing.freeze_support()proc_init(testcase0, testcase1, testcase2, testcase3)logical_cores = os.cpu_count()print("cpu num: ", logical_cores)main()sys.exit(0)