paho-mqtt: callback thread

Question

Я выполняю работу MQTT в python с paho-mqtt. Все многопоточные потоки on_message() в разных потоках, так что если одна из задач занимает много времени, другие сообщения все равно могут быть обработаны? Если нет, как я могу добиться такого поведения?

Благодарим за помощь!

Answer 1

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

В Java вы должны использовать обратный вызов onMessage для включения входящего сообщения в локальную очередь, с которой будет работать отдельный пул потоков.

Python не имеет встроенной поддержки потоковой передачи, но имеет поддержку процессов нереста, которые действуют как потоки. Подробная информация о многопроцессорной можно найти здесь:

https://docs.python.org/2.7/library/multiprocessing.html

EDIT: На приглядевшись в коде ПОЗ питона немного ближе кажется, что на самом деле может начать новую нить (с помощью функции loop_start()) для обработки сетевой стороны вещей, ранее требующих функции цикла. Это не изменяет тот факт, что все вызовы обратного вызова on_message будут выполняться в этом потоке. Если вам нужно делать большие объемы работы в этом обратном вызове, вам обязательно нужно посмотреть пул новых потоков для выполнения этой работы.

http://www.tutorialspoint.com/python/python_multithreading.htm