Mik*_*ash 2 python-multithreading python-3.x
import threading, socket, sys, time
from queue import Queue
print_lock = threading.Lock()
if len(sys.argv) !=2 :
print ("Usage: portscan.py <host>")
sys.exit(1)
host = sys.argv[1]
def scan(port):
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
try:
con = s.connect((host, port))
with print_lock:
print('Port: ' + str(port) + ' is open')
con.close()
except:
pass
def threader():
while true:
worker = q.qet()
scan(worker)
q.task_done()
q = Queue()
for x in range(100):
t = threading.Thread(target=threader)
t.daemon = True
t.start
for worker in range(1, 1024):
q.put(worker)
q.join()
Run Code Online (Sandbox Code Playgroud)
当我运行它时,它只是挂起,我没有得到任何结果,也没有给我任何错误。我不明白为什么它不起作用。当我不添加线程功能时它确实有效。
小智 5
其中存在三个小错误:
这个更正后的代码似乎对我有用:
import threading, socket, sys, time
from queue import Queue
print_lock = threading.Lock()
if len(sys.argv) !=2 :
print ("Usage: portscan.py <host>")
sys.exit(1)
host = sys.argv[1]
def scan(port):
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
try:
con = s.connect((host, port))
with print_lock:
print('Port: ' + str(port) + ' is open')
con.close()
except:
pass
def threader():
while True:
worker = q.get()
scan(worker)
q.task_done()
q = Queue()
for x in range(100):
t = threading.Thread(target=threader)
t.daemon = True
t.start()
for worker in range(1, 1024):
q.put(worker)
q.join()
Run Code Online (Sandbox Code Playgroud)
| 归档时间: |
|
| 查看次数: |
4757 次 |
| 最近记录: |