Как избежать чередованных журналов в параллельной обработке? ⇐ Python

[Anonymous]

Наивно параллелизируя некоторые задачи, которые включают в себя результаты ведения журнала в чередующихся журналах: < /p>

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

import logging
from concurrent.futures import ThreadPoolExecutor
from time import sleep

logger = logging.getLogger(__name__)

def task(n):
logger.info(f"Task {n} started")
sleep(0.001)
logger.info(f"Task {n} finished")
return n * n

def main():
with ThreadPoolExecutor(max_workers=2) as executor:
futures = [executor.submit(task, i) for i in range(5)]
_ = [f.result() for f in futures]

if __name__ == "__main__":
logging.basicConfig(level=logging.INFO)
main()

---

INFO:__main__:Task 0 started
INFO:__main__:Task 1 started
INFO:__main__:Task 0 finished
INFO:__main__:Task 2 started
INFO:__main__:Task 1 finished
INFO:__main__:Task 3 started
INFO:__main__:Task 2 finished
INFO:__main__:Task 4 started
INFO:__main__:Task 3 finished
INFO:__main__:Task 4 finished
< /code>
Но я хочу, чтобы журналы не были чередованы, и я готов пожертвовать доставкой журналов в режиме реального времени в каждом процессе, чтобы это произошло: < /p>
INFO:__main__:Task 1 started
INFO:__main__:Task 1 finished
INFO:__main__:Task 0 started
INFO:__main__:Task 0 finished
INFO:__main__:Task 4 started
INFO:__main__:Task 4 finished
INFO:__main__:Task 2 started
INFO:__main__:Task 2 finished
INFO:__main__:Task 3 started
INFO:__main__:Task 3 finished

Есть ли простой способ получить этот тип поведения?

Подробнее здесь: https://stackoverflow.com/questions/796 ... processing