Python – ограничение потоков в цикле for

я пытаюсь ограничить этот цикл до 4 одновременных заданий:

def testSSH(host, user, password, port):
s = pxssh.pxssh()
try:
    if not s.login (host, username=user, password=password, port=port):
        print(password)
        return False
    else:
        print(password)
        return True
except:
    print(password)
    return False




passes = "r", "1234", "12345", "123456!", "1234567", "a", "b", "e", "s", "A", "d", "66"

jobs = []
for passw in passes:
    thread = threading.Thread(target=testSSH, args=("localhost", "myuser", passw, "22",))
    jobs.append(thread)

for j in jobs:
        print(threading.active_count())
        j.start()

for j in jobs:
        j.join()

код работает нормально. однако я не могу ограничить одновременные задания. threading.active_count() всегда является значением проходов. какие-нибудь советы? я пробовал этот вопрос, но ничего не вышло Спасибо!

для ограничения ресурсов, подобных этому, не могли бы вы использовать семафоры?

— 11.03.2019 19:53

Возможный дубликат Правильный способ ограничить максимальное количество потоков, работающих одновременно?

— 11.03.2019 19:53

можете ли вы прислать пример использования семафоров в коде, подобном этому?

— 11.03.2019 20:01

python python-3.x multithreading

11.03.2019 19:50

Почему в Python есть оператор "pass"?

Оператор pass в Python - это простая концепция, которую могут быстро освоить даже новички без опыта программирования.

Некоторые методы, о которых вы не знали, что они существуют в Python

Python - самый известный и самый простой в изучении язык в наши дни. Имея широкий спектр применения в области машинного обучения, Data Science,...

Основы Python Часть I

Вы когда-нибудь задумывались, почему в программах на Python вы видите приведенный ниже код?

LeetCode - 1579. Удаление максимального числа ребер для сохранения полной проходимости графа

Алиса и Боб имеют неориентированный граф из n узлов и трех типов ребер:

Оптимизация кода с помощью тернарного оператора Python

И последнее, что мы хотели бы показать вам, прежде чем двигаться дальше, это

Советы по эффективной веб-разработке с помощью Python

Как веб-разработчик, Python может стать мощным инструментом для создания эффективных и масштабируемых веб-приложений.

288

Ответы 1

ОК, ребята, я нашел кое-что сам:

threads = 0
def testSSH(host, user, password, port):
s = pxssh.pxssh()
try:
    if not s.login (host, username=user, password=password, port=port):
        print(password)
        return False
    else:
        print(password)
        return True
except:
    print(password)
    return False




passes = "r", "1234", "12345", "123456!", "1234567", "a", "b", "e", "s", "A", "d", "66"

jobs = []
for passw in passes:
    thread = threading.Thread(target=testSSH, args=("localhost", "myuser", passw, "22",))
    jobs.append(thread)

for j in jobs:
    threads = threading.active_count()
    while threads > 4:
    time.sleep(0.05)
    threads = threading.active_count()
        j.start()

for j in jobs:
        j.join()

надеюсь, это поможет кому-то в будущем...

11.03.2019 21:04