mongo.py 文件源码

def multiDownload(self):
        #????????????????????????????
        #????CPU?????????????????
        starttime = datetime.datetime.now()

        """????????"""
        self.get_symbol()
        cx = self.Symbol_Db['equity'].find()
        symbolSet = set([d['code'] for d in cx])  # ????????
        p = ThreadPool(100)
        p.map(self.downloadEquityAllData, symbolSet)
        p.close()
        p.join()

        endtime = datetime.datetime.now()
        print "??: " + str(endtime - starttime)