python: 多进程实例

1. 实例一

• 主进程跟子进程的通过两个队列实现全双工通讯；
  
• 如有需要主进程会提示窗口输入信息传输给子进程；
  
• 假如子进程收到主进程的消息，会弹窗提示收到的消息；
  
• 子进程弹窗提示进程即将结束；
  
  
  
  
• 具体代码如下
  

1. # -*- coding: utf-8 -*-
2. # @Time    : 30/07/2024  09:58 AM
3. # @FileName: main.py
4. # @PythonVersion : (3, 7)
5. import multiprocessing
6. import random
7. import threading
8. import time
10. import FreeSimpleGUI as sg
13. def worker(num, main_queue, sub_queue, lock):
14.     """子进程工作函数"""
16.     x = None
17.     time.sleep(1)  # 模拟长时间运行的任务
18.     msg = random.choice([True, False])
19.     if msg is True:
20.         with lock:
21.             message = f'进程 {num} 需要修改！'
22.             sub_queue.put(message)
23.             x = main_queue.get()
24.     if x:
25.         sg.popup(f"子进程{num}收到主进程发送过来的信息：{x}", keep_on_top=True)
26.     sg.popup(f"子进程{num}进程已结束！", keep_on_top=True)
27.     print(F"进程 {num} 执行完成！")
30. def thread_worker(main_queue, sub_queue, lock, num_processes):
31.     """子线程工作函数，启动进程池并管理管道"""
33.     with multiprocessing.Pool(processes=num_processes) as pool:
34.         # 启动子进程并将结果放入队列
35.         pool.starmap(worker, [(i, main_queue, sub_queue, lock) for i in range(num_processes)])
36.         pool.close()
37.         pool.join()
39.     sub_queue.put("任务都已执行完成！")
42. def main():
43.     layout = [
44.         [sg.Button('启动任务')],
45.         [sg.Text('', size=(30, 1), key='-OUTPUT-')]
46.     ]
48.     window = sg.Window('主窗口', layout)
50.     # 使用 Manager.Queue 来跟踪子进程的结果
51.     manager = multiprocessing.Manager()
52.     lock = manager.Lock()
53.     main_queue = manager.Queue()
54.     sub_queue = manager.Queue()
56.     while True:
57.         event, values = window.read(timeout=100)
59.         if event == sg.WIN_CLOSED:
60.             break
62.         if event == '启动任务':
63.             # 启动子线程
64.             threading.Thread(target=thread_worker, args=(main_queue, sub_queue, lock, 5), daemon=True).start()
66.         # 处理来自进程的消息
67.         while not sub_queue.empty():
68.             message = sub_queue.get()
69.             if not message == "任务都已执行完成！":
70.                 window['-OUTPUT-'].update(message)
71.                 main_queue.put(sg.popup_get_text(message + "主进程输入修改值"))
72.             else:
73.                 window['-OUTPUT-'].update(message)
75.     window.close()
78. if __name__ == "__main__":
79.     main()

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。