Py学习  »  Python

python:pathos多处理池调用类外函数

jason • 6 年前 • 2048 次点击  

我想在课堂上做多处理。似乎只有病理学多处理才能帮助我。但是,当我实现它时,它无法加载我在主函数中使用的包。

from pathos.multiprocessing import ProcessingPool;
import time
import sys;
import datetime


class tester:
    def __init__(self):
        self.pool=ProcessingPool(2);

    def func(self,msg):
        print (str(datetime.datetime.now()));
        for i in xrange(1):
            print msg
            sys.stdout.flush();
        time.sleep(2)    

#----------------------------------------------------------------------
    def worker(self):
        """"""
        pool=self.pool
        for i in xrange(10):
               msg = "hello %d" %(i)
               pool.map(self.func,[i])
        pool.close()
        pool.join()
        time.sleep(40)



if __name__ == "__main__":
    print datetime.datetime.now();
    t=tester()
    t.worker()
    time.sleep(60);
    print "Sub-process(es) done."

错误的是未定义全局名称“datetime”。但它的主要功能是! 我的系统是Win7。

Python社区是高质量的Python/Django开发社区
本文地址:http://www.python88.com/topic/41048
文章 [ 1 ]  |  最新文章 6 年前