[已解决]关于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没试过。

跳转到最佳答案楼层