像绅士一样去征服 2021-08-22 10:18 采纳率: 100%
浏览 90
已结题

python 多进程消息队列问题

from multiprocessing import Process, Queue

q = Queue()  # 创建消息队列

# 子进程
def handle():
   print(q.get())

#主进程
if __name__ == '__main__':
    p = Process(target=handle)
    p.start()
    cmd = input("请输入选择\n")
    q.put(cmd)

为什么主进程写入消息队列的数据,子进程读不出来呢?

  • 写回答

1条回答 默认 最新

  • 天元浪子 Python领域优质创作者 2021-08-22 11:40
    关注

    进程间使用队列通讯时,队列应作为进程函数的参数传递进去。另外,子进程通常要设置进程守护。

    from multiprocessing import Process, Queue
    
    q = Queue()  # 创建消息队列
    
    def handle(q):
       print('Start...')
       print(q.get())
       print('Over.')
    
    if __name__ == '__main__':
        p = Process(target=handle, args=(q, ))
        p.daemon = True # 设置进程守护
        p.start()
        cmd = input("请输入选择\n")
        print(q.empty())
        q.put(cmd)
        print(q.empty())
        
        input() # 利用该函数阻塞主进程以守护子进程,是我在测试时的习惯做法
    
    
    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论

报告相同问题?

问题事件

  • 系统已结题 8月30日
  • 已采纳回答 8月22日
  • 创建了问题 8月22日

悬赏问题

  • ¥15 公交车和无人机协同运输
  • ¥15 stm32代码移植没反应
  • ¥15 matlab基于pde算法图像修复,为什么只能对示例图像有效
  • ¥100 连续两帧图像高速减法
  • ¥15 组策略中的计算机配置策略无法下发
  • ¥15 如何绘制动力学系统的相图
  • ¥15 对接wps接口实现获取元数据
  • ¥20 给自己本科IT专业毕业的妹m找个实习工作
  • ¥15 用友U8:向一个无法连接的网络尝试了一个套接字操作,如何解决?
  • ¥30 我的代码按理说完成了模型的搭建、训练、验证测试等工作(标签-网络|关键词-变化检测)