leeyns 2020-02-25 15:31 采纳率: 0%
浏览 463

mac 系统中 python 的 multiprocessing模块的使用问题

multiprocessing中使用Queue,在给进程传递队列参数时系统报错。
代码如下,使用python3.8编译。只要传输Queue定义的参数就报错,
报错信息如下。

图片说明

import multiprocessing


def download_from_web(q):
    """下载数据"""
    # 模拟从网上下载的数据
    data = [11, 22, 33, 44]

    # 向队列中写入数据
    for temp in data:
        q.put(temp)

    print("下载器已经下载完了数据并且存入到队列中")


def analyse_data(q):
    """数据处理"""
    waiting_analyse_data = list()
    # 从队列中获取数据
    while True:
        data = q.get()
        waiting_analyse_data.append(data)

        if q.empty():
            break
    # 模拟数据处理
    print(waiting_analyse_data)

def main():
    # 1. 创建一个队列
    q = multiprocessing.Queue()
    # 2. 创建多个进程,将队列的引用当做实参进行传递到里面

    p1 = multiprocessing.Process(target=download_from_web, args=(q,))
    p2 = multiprocessing.Process(target=analyse_data, args=(q,))

    p1.start()
    p2.start()


if __name__ == "__main__":
    main()
  • 写回答

2条回答 默认 最新

  • 史枭 2021-01-08 17:28
    关注

    我也是这样,Mac报错,Ubuntu没问题

    评论

报告相同问题?

悬赏问题

  • ¥20 delta降尺度方法,未来数据怎么降尺度
  • ¥15 c# 使用NPOI快速将datatable数据导入excel中指定sheet,要求快速高效
  • ¥15 再不同版本的系统上,TCP传输速度不一致
  • ¥15 高德地图点聚合中Marker的位置无法实时更新
  • ¥15 DIFY API Endpoint 问题。
  • ¥20 sub地址DHCP问题
  • ¥15 delta降尺度计算的一些细节,有偿
  • ¥15 Arduino红外遥控代码有问题
  • ¥15 数值计算离散正交多项式
  • ¥30 数值计算均差系数编程