from socket import *
import threading
import queue

threads = []
q = queue.Queue()
for i in range(1, 255):
    ip_addr = '10.7.67.' + str(i)
    for port in [21, 22, 20, 80, 8080, 8081, 3389, 443, 445, 3306, 445]:
        q.put((ip_addr, port))

def portScanner(q):
    while True:
        addr = None
        try:
            addr = q.get_nowait()
        except queue.Empty:
            print("finished")
            break
        #print('[-] [%s] %d scanning' % (addr[0], addr[1]))
        try:
            s = socket(AF_INET,SOCK_STREAM)
            s.connect((addr[0], addr[1]))
            print('[+] [%s] %d open!!!' % (addr[0], addr[1]))
            s.close()
        except:
            continue

def main():
    setdefaulttimeout(2)
    thread_num = 50
    for i in range(thread_num):
        args = {'q': q}
        t = threading.Thread(target=portScanner, kwargs=args)
        threads.append(t)
        t.start()
    for t in threads:
        t.join()
    print('[*] The scan is complete!')

if __name__ == '__main__':
    main()