zoukankan      html  css  js  c++  java
  • python多进程 multiprocessing之参数使用必须是可以序列化的。

    在进行数据传输的时候,在Python中我们可以通过pickle模块对对象进行序列化后进行传输,然后通过反序列化后进行使用。

    今天在看《Python3标准版库》书籍中看到

    与threading不同,要向一个multiprocessing Process传递参数,这个参数必须能够用pickle串行化。也就是说,传入的参数必须为可序列化的。

    我找了半天,网上查了很久,终于找到模块对象是不可被序列化的。

    import threading
    
    
    def worker(num):
        print('worker', num)
    
    if __name__ == '__main__':
    
        jobs = []
        for i in range(5):
            # p = multiprocessing.Process(target=worker, args=(multiprocessing,))
            p = threading.Thread(target=worker, args=(multiprocessing,))
            jobs.append(p)
            p.start()
    

      

    上面的代码中,如果使用多进行就无法执行,个人感觉多进程需要复制不同的对象,用于各个进程之间的使用,参数对象,可以通过pickle的方式进行复制,但模块对象在一个Python进程中是共享的,

    所以pickle不能进行,这样分析的话,只要在一个Python项目运行中,该对象是唯一的,那该对象就不能进行pickle,也不知道正确与否,忘指教。

  • 相关阅读:
    Stalstack 连接管理配置
    Stalstack 安装
    Apache 错误整理
    Apache 服务常用命令
    Apache 优化
    Shell 常用技巧
    Nginx+keepalived做双机热备加tomcat负载均衡
    用Lighttpd做图片服务器
    rsync是类unix系统下的数据镜像备份工具
    redis+keeplived分布式缓存
  • 原文地址:https://www.cnblogs.com/sidianok/p/14745166.html
Copyright © 2011-2022 走看看