threadCount = 30 #指定线程数 reader = readCsv() for i in reader: #写入队列 q.put(i) while threading.activeCount() < threadCount: if q.empty() != True: data = q.get() t = threading.Thread(target=handler,args=(data,)) t.start() else: threadCount = 0 print 'Import All Data Successful!'
功能 : 读取csv中的4w条数据到队列中,多线程写入数据库,只能执行和线程数差不多的条数,就会正常结束.
看起来应该是线程没有退出的问题,大神帮我看下这点代码,哪里出问题了,稀里糊涂了
Camel97
相关分类