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条数据到队列中,多线程写入数据库,只能执行和线程数差不多的条数,就会正常结束.看起来应该是线程没有退出的问题,大神帮我看下这点代码,哪里出问题了,稀里糊涂了
添加回答
举报
0/150
提交
取消