Python: блок threading.ThreadPython

Программы на Python
Anonymous
Python: блок threading.Thread

Сообщение Anonymous »

Код: Выделить всё

import pymysql
from multiprocessing.pool import ThreadPool

def process(item):
host = str(item).strip()
db = None
try:
db = pymysql.connect(host=host, user='root', passwd='root', port=3306, connect_timeout=10,
write_timeout=10)
r = open("success.txt", 'a')
r.write(host)
r.write("\n")
pass
except Exception as msg:
print(msg)
pass
finally:

if db:
db.close()
pass

if __name__ == '__main__':
t = ThreadPool(100)
t.map_async(process,open('3306.txt').readlines())
t.close()
t.join()

Я хочу проверить в пакетном режиме, действительны ли пароли учетных записей MySQL для некоторых IP-адресов, но в моем коде возникнет проблема блокировки подпотоков. Фактически последний IP проверен, но основной поток не завершился. Я не знаю, как его изменить. Можете ли вы внести некоторые изменения и предложения?

Подробнее здесь: https://stackoverflow.com/questions/717 ... read-block

Вернуться в «Python»