新手求解答多线程问题

coolxl2014

麻烦大牛帮忙看下这个脚本，用socket.connect分别去连接192.168.2.x这个ip段的15个端口，扫描开放状态。超时是2秒，根据我新手的理解。如果扫描1个ip的15个端口，15个线程，应该2秒内能打印出所以结果。但实际情况是结果一条条往外冒，和单线程一样慢。 求大牛帮小弟指出错误。多谢~

1. # -*- coding: utf-8 -*-
   
2. import threading, socket
   
3. 
   
4. def host_list(start,end):
   
5.     for i in range(start,end,1):   
   
6.         ip = net+str(i)
   
7.         for x in PortList:        
   
8.             port = x
   
9.             tmp = []
   
10.             tmp.append(ip)
    
11.             tmp.append(port)
    
12.             list.append(tmp)
    
13.     return list
    
14. 
    
15. def scan(list):
    
16.     while True:        
    
17.         if len(list)>0:
    
18.             lock.acquire()
    
19.             host = list.pop()
    
20.             lock.release()
    
21.             ip = host[0]
    
22.             port = host[1]
    
23.             sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    
24.             sock.settimeout(Timeout)
    
25.             address = (ip, port)            
    
26.             try:
    
27.                 sock.connect(address)
    
28.                 print ip,port,'True'
    
29.             except:
    
30.                 sock.close()
    
31.                 print ip,port,'False'
    
32.             sock.close()
    
33.         else:
    
34.             break
    
35. 
    
36. def threads(x):
    
37.     thread_tmp=[]
    
38.     for i in range(x):
    
39.         new_thread=threading.Thread(target=scan(host), args=(i),name='thread'+str(i))
    
40.         thread_tmp.append(new_thread)
    
41.     for i in thread_tmp:
    
42.         i.start()
    
43.         i.join()
    
44. 
    
45. 
    
46. if __name__ == '__main__':
    
47.     net = '192.168.2.'
    
48.     Timeout = 2.0
    
49.     PortList = [21, 22, 23, 25, 80, 135, 137, 139, 445, 1433, 1502, 3306, 3389, 8080, 9015]
    
50.     list = []
    
51.     true_list = []
    
52.     false_list = []
    
53.     lock = threading.Lock()
    
54.     host = host_list(1,2)
    
55.     threads(15)
    

复制代码

whitelotus19

没仔细看，感觉这里这么写吧

1. for i in thread_tmp:
   
2.     i.start()
   
3. for i in thread_tmp:   
   
4.     i.join()

复制代码