Python多线程问题

Hadron74

回复 1# z0415010
试着写了一个，应该满足你的要求。抛砖引玉：

1. 
   
2. import threading
   
3. import time
   
4. from collections import deque
   
5. 
   
6. command_list = deque([ "sleep {} ".format(i) for i in range(1,10,1)])
   
7. 
   
8. def worker(command):
   
9.     from subprocess import call
   
10.     call(command,shell=True)
    
11.     print "Finished {}".format(command)
    
12.     return
    
13. 
    
14. NUMBER_THREADS = 5
    
15. TIME_INTERVAL = 0.5
    
16. 
    
17. def run():
    
18.     command = command_list.pop()
    
19.     t = threading.Thread(target=worker, args=(command,))
    
20.     t.start()
    
21. 
    
22. for i in range(NUMBER_THREADS):
    
23.     run()
    
24. 
    
25. while command_list:
    
26.     time.sleep(TIME_INTERVAL)
    
27.     alive_threads = threading.enumerate()
    
28.     lat = len(alive_threads)
    
29.     if lat == 1 : break
    
30.     if lat <= NUMBER_THREADS : run()

复制代码

1. Finished sleep 5
   
2. Finished sleep 6
   
3. Finished sleep 7
   
4. Finished sleep 8
   
5. Finished sleep 9
   
6. Finished sleep 4
   
7. Finished sleep 1
   
8. Finished sleep 2
   
9. Finished sleep 3
   

复制代码

Hadron74

回复 4# q1208c

能贴出来吗？多线程不熟，正好学学。谢谢！
   

Hadron74

回复 6# mswsg

这个好！