xuk13523892087 2018-11-29 07:00 采纳率: 50%
浏览 1662
已采纳

python 进程池调用自定义类 没有反应 大佬们来看看

# coding: utf-8
import multiprocessing
import time
import os
class Count(object):
    def __init__(self, list):
        self.a = list[0]
        self.b = list[1]

    def run(self):
        if self.a >= 50:
            time.sleep(3)
            print(self.a,self.b)
        else:
            time.sleep(2)
            print("{}<50".format(self.a),self.b,os.getpid())

pool = multiprocessing.Pool(5)
list = [[35, 1], [67, 2], [45, 1], [77, 2], [55, 2]]

t1 = time.time()
for i in list:
    pool.apply_async(func=Count(i).run)
pool.close()
pool.join()
t2 = time.time()
print(t2-t1)


方法没有输出, 大佬们帮看下

  • 写回答

1条回答 默认 最新

  • 西哇哇 2018-11-29 14:36
    关注

    定义入口函数

     if __name__ == '__main__':
        pool = multiprocessing.Pool(processes=3)
        list = [[35, 1], [67, 2], [45, 1], [77, 2], [55, 2]]
    
        for i in list:
            pool.apply_async(func=Count(i).run)
        pool.close()
        pool.join()
        # t2 = time.time()
        # print(t2-t1)
    

    你这个代码,我这个强迫症看着很难受呀~

    顺便帮你改了一下,代码 不谢~

    import multiprocessing
    import os
    
    
    class Count(object):
        def __init__(self, list):
            self.a, self.b = list
    
        def run(self):
            return (self.a, self.b) if self.a >= 50 else ("{}<50".format(self.a), self.b, os.getpid())
    
    
    if __name__ == '__main__':
        pool = multiprocessing.Pool(processes=5)
        params = [[35, 1], [67, 2], [45, 1], [77, 2], [55, 2]]
        res = [pool.apply_async(Count(val).run).get() for val in params if isinstance(val, list)]
        pool.close()
        pool.join()
        print(res)
    
    

    对了,还有一个小问题,变量名不要和python关键字一样~ list

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论

报告相同问题?

悬赏问题

  • ¥20 怎么在stm32门禁成品上增加记录功能
  • ¥15 Source insight编写代码后使用CCS5.2版本import之后,代码跳到注释行里面
  • ¥50 NT4.0系统 STOP:0X0000007B
  • ¥15 想问一下stata17中这段代码哪里有问题呀
  • ¥15 flink cdc无法实时同步mysql数据
  • ¥100 有人会搭建GPT-J-6B框架吗?有偿
  • ¥15 求差集那个函数有问题,有无佬可以解决
  • ¥15 【提问】基于Invest的水源涵养
  • ¥20 微信网友居然可以通过vx号找到我绑的手机号
  • ¥15 解riccati方程组