Код: Выделить всё
import time
import random
import logging
import logging.handlers
from multiprocessing.dummy import Pool
def do_something(number):
logger.info(number)
time.sleep(number/100)
logger = logging.getLogger(__name__)
handler = logging.StreamHandler()
handler.setFormatter(logging.Formatter("%(asctime)s [%(levelname)-7s] (%(threadName)-10s) %(message)s"))
logger.addHandler(handler)
logger.setLevel(logging.INFO)
numbers = random.sample(range(1, 101), 50)
pool = Pool(4)
pool.imap_unordered(do_something, numbers)
pool.close()
pool.join()
что -то вроде этого:
codm it spect it it it spect with codm. Просто сделать: < /p>
Код: Выделить всё
for _ in tqdm.tqdm(pool.imap_unordered(do_something, numbers), total=len(numbers)):
pass
Подробнее здесь: https://stackoverflow.com/questions/796 ... multiproce