论坛徽章:: 0

电梯直达

1楼 [收藏(0)] [报告]

发表于 2012-03-07 14:58 |只看该作者 |倒序浏览

Reader = csv.reader(open('aa.csv'))
for row in Reader:
ipadd=row[1]
thread = JKThread(ipadd)
thread.start()

这是最后调用的一段

是用继承的方式写了个threading 重写的run()
现在是aa.csv有多少行就开多个少线程，然后会有报错
想控制线程的数量，因为加上join()方法就正常的。

麻烦问下应该怎么写，谢谢。

文库|博客

timespace

大富大贵

论坛徽章:: 11

2楼 [报告]

发表于 2012-03-07 15:37 |只看该作者

这表达也太不清楚了。。。
想以什么逻辑控制线程数量？aa.csv多行对应一个线程或其它什么规则？
不要让人猜你的想法啊

实战分享：从技术角度谈机器学习入门| 【大话IT】RadonDB低门槛向MySQL集群下战书 | ChinaUnix打赏功能已上线！ | 新一代分布式关系型数据库RadonDB知多少？

liu.xin

白手起家

论坛徽章:: 0

3楼 [报告]

发表于 2012-03-07 15:40 |只看该作者

用for 所以一行对应一个线程
什么逻辑都可以了
只要能控制数量就行

实战分享：从技术角度谈机器学习入门| 【大话IT】RadonDB低门槛向MySQL集群下战书 | ChinaUnix打赏功能已上线！ | 新一代分布式关系型数据库RadonDB知多少？

askandstudy

家境小康

论坛徽章:: 0

4楼 [报告]

发表于 2012-03-09 15:18 |只看该作者

在起线程的地方把线程对象保存到一个列表或字典之类的变量中，线程结束时让线程对象自己把自己从这个变量中删除掉，或在主线程中定期检查是否有线程已经结束，有就在变量中删除已经结束的线程引用。
主线程中起线程时就判断列表或字典项长度，再定期检查这个变量的长度，不就可以控制线程数。
做法比较土
或者找些现成提供线程池管理的模块来使用，大概这样比较好。