[已解决]关于threads多次开始的疑问

huomqh

比如有下面一段代码：

1. # coding = utf-8
   
2. import time
   
3. import threading
   
4. import random
   
5. 
   
6. def p(i):
   
7.     print (i)
   
8.     time.sleep(random.randint(1,3))
   
9.     print(i)
   
10. 
    
11. threads2 = []
    
12. 
    
13. for i in range(0, 2):
    
14.     threads2.append(threading.Thread(target=p, args=(i,)))
    
15. while 1:
    
16.     time.sleep(10)
    
17.     for t in threads2:
    
18.         t.start()

复制代码

运行后会有如下报错信息。

这个应该是threads只能运行一次吧。但是我的程序就是要定时或者每过多少时间去启动一次这些线程（可以保证上一次运行的已经全部结束）。那么怎么办呢？

最佳答案

月排行榜 / 总排行榜

wei_Y

2016-10-18 16:44:46

如果用的python3可以试试这样。

1. from concurrent.futures import ThreadPoolExecutor
   
2. 
   
3. import time
   
4. 
   
5. def a(v, i):
   
6.     print(v)
   
7.     time.sleep(i)
   
8. 
   
9. 
   
10. with ThreadPoolExecutor(max_workers=2) as t:
    
11.     t.submit(a, '5', 10)
    
12.     t.submit(a, '6', 5)
    
13.     t.submit(a, '7', 7)
    
14.     t.submit(a, '8', 9)  

复制代码

加个while就行了。

2没试过。

跳转到最佳答案楼层

SixPy

while 循环写到线程里

wei_Y

如果用的python3可以试试这样。

1. from concurrent.futures import ThreadPoolExecutor
   
2. 
   
3. import time
   
4. 
   
5. def a(v, i):
   
6.     print(v)
   
7.     time.sleep(i)
   
8. 
   
9. 
   
10. with ThreadPoolExecutor(max_workers=2) as t:
    
11.     t.submit(a, '5', 10)
    
12.     t.submit(a, '6', 5)
    
13.     t.submit(a, '7', 7)
    
14.     t.submit(a, '8', 9)  

复制代码

加个while就行了。

2没试过。

duanshui1184

1. while 1:
   
2.     time.sleep(10)
   
3.     for t in threads2:
   
4.         print t.__dict__
   
5.         t.start()

复制代码

尝试打印t
会发现while 第一次进和第二次进入 threads2元素的值是不同的
第一次:
{'_Thread__ident': None, '_Thread__block': <Condition(<thread.lock object at 0x7f01140361f0>, 0)>, '_Thread__name': 'Thread-1', '_Thread__daemonic': False, '_Thread__started': <threading._Event object at 0x7f0113f29dd0>, '_Thread__stderr': <open file '<stderr>', mode 'w' at 0x7f01140851e0>, '_Thread__target': <function p at 0x7f0112072668>, '_Thread__kwargs': {}, '_Verbose__verbose': False, '_Thread__args': (0,), '_Thread__stopped': False, '_Thread__initialized': True}
第二次:
{'_Thread__ident': 139642559399680, '_Thread__block': <Condition(<thread.lock object at 0x7f01140361f0>, 0)>, '_Thread__name': 'Thread-1', '_Thread__daemonic': False, '_Thread__started': <threading._Event object at 0x7f0113f29dd0>, '_Thread__stderr': <open file '<stderr>', mode 'w' at 0x7f01140851e0>, '_Verbose__verbose': False, '_Thread__stopped': True, '_Thread__initialized': True}
所以把生成threads2变量的循环封装到一个函数里就好了 for t in get_threads()类似