0

Я пишу многопоточное(threading) консольное приложение на Python, мне необходимо выводить информацию в консоль из всех потоков,но при использовании print() не понятно к какому потоку относиться информация и вообще информация трудно читаема.
Как правильнее и удобнее выводить информацию?

5
  • Ну обычно в начале каждой строки выводят какой-нибудь идентификатор потока. Какого-то универсального идеального решения нет.
    – Alexey Ten
    12 мая 2022 в 16:25
  • @AlexeyTen ,так я тоже пробывал,но читаемость это не повешает
    – minicx
    12 мая 2022 в 16:26
  • 1
    Ну если не нужно хранить предыдущее сообщение то все просто - выделить каждому потоку по строке и пусть туда пишет. Там многопоточные прогрессбары работают.
    – vitidev
    12 мая 2022 в 16:38
  • 1
    Зависит от задачи. Если это типа логирование, то вместо print используйте модуль logging. Во-первых, там легко добавить дополнительную информацию, типа времени и потока ко всем сообщениям глобально. Во-вторых, модуль позаботится о том чтоб вывод не перемешивался. Если же это сложный UI где разные потоки выводят свои данные, то возможно, вы ищете docs.python.org/3/howto/curses.html 12 мая 2022 в 16:46
  • @Roman-StopRUaggressioninUA ,попробую
    – minicx
    12 мая 2022 в 16:48

1 ответ 1

3

%(processName)s и %(threadName)s для logging format

import logging, multiprocessing

formatter = '%(asctime)s levelname[%(levelname)s] processName[%(processName)s] threadName[%(threadName)s] pathname[%(pathname)s] funcName[%(funcName)s] lineno[%(lineno)d]\n%(message)s'
logging.basicConfig(level=logging.INFO, datefmt='%H:%M:%S', format=formatter, handlers=[logging.StreamHandler(), ],)

def threads(n):
    logging.info(f'mp {n}')
    with multiprocessing.pool.ThreadPool(processes=2) as p:
        p.map(lambda i: logging.info(f'th {i}'), range(3))

if __name__ == '__main__':
    multiprocessing.freeze_support()
    logging.info('Start')
    with multiprocessing.Pool(processes=2) as p:
        p.map(threads, range(2))

out:

13:08:05 levelname[INFO] processName[MainProcess] threadName[MainThread] pathname[C:\SCR\NEW_JIRA\sdas.py] funcName[<module>] lineno[13]
Start
13:08:06 levelname[INFO] processName[SpawnPoolWorker-2] threadName[MainThread] pathname[C:\SCR\NEW_JIRA\sdas.py] funcName[threads] lineno[7]
mp 0
13:08:06 levelname[INFO] processName[SpawnPoolWorker-2] threadName[Thread-1 (worker)] pathname[C:\SCR\NEW_JIRA\sdas.py] funcName[<lambda>] lineno[9]
th 0
13:08:06 levelname[INFO] processName[SpawnPoolWorker-2] threadName[Thread-1 (worker)] pathname[C:\SCR\NEW_JIRA\sdas.py] funcName[<lambda>] lineno[9]
th 1
13:08:06 levelname[INFO] processName[SpawnPoolWorker-2] threadName[Thread-1 (worker)] pathname[C:\SCR\NEW_JIRA\sdas.py] funcName[<lambda>] lineno[9]
th 2
13:08:06 levelname[INFO] processName[SpawnPoolWorker-2] threadName[MainThread] pathname[C:\SCR\NEW_JIRA\sdas.py] funcName[threads] lineno[7]
mp 1
13:08:06 levelname[INFO] processName[SpawnPoolWorker-2] threadName[Thread-6 (worker)] pathname[C:\SCR\NEW_JIRA\sdas.py] funcName[<lambda>] lineno[9]
th 0
13:08:06 levelname[INFO] processName[SpawnPoolWorker-2] threadName[Thread-6 (worker)] pathname[C:\SCR\NEW_JIRA\sdas.py] funcName[<lambda>] lineno[9]
th 1
13:08:06 levelname[INFO] processName[SpawnPoolWorker-2] threadName[Thread-6 (worker)] pathname[C:\SCR\NEW_JIRA\sdas.py] funcName[<lambda>] lineno[9]
th 2

Ваш ответ

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

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