1

всем привет! есть код:

for line in friends:
    threading.Thread(target=messages, args=(line,)).start()

который успешно рассылает людям сообщения. возник вопрос: как ограничить количество потоков, если например friends больше 50 строк? и нужно ли потоки как то закрывать после их работы?

2 ответа 2

4

Используйте ThreadPoolExecutor:

with ThreadPoolExecutor(max_workers=8) as executor:
    for line in friends:
        executor.submit(messages, line)
1

pool.map() лучше всего подходит для списков. Пула обычных потоков нет в модуле threading, но в модуле multiprocessing есть интерфейсы к Thread-ам.

from multiprocessing.pool import ThreadPool

def messages(line):
    pass

pool = ThreadPool(processes=8)
results = pool.map_async(messages,friends)

Потоки закрывать не нужно. Их удалит GC, если их никуда не сохранить перед запуском.

В Питоне также есть старые добрые threading.Semaphore

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge you have read our privacy policy.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.