alex55555LemkolegНужно, чтобы один из потоков занимался тем, что вызывал определенные методы из других потоков
Поциенту изучать методы wait и notify, а так же конструкцию synchronize.

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

Вообще походу модель видется примерно так первая очередь как Prod/Cos и вторая топик как Pub/Sub если объем данных большой, то где нибудь таблицу повесить в Редисе или еще в каком кеше.

LemkolegSergunka,
Вторая очередь не решает проблем таких как:
1) излишних опросов потоками, ожидающих ответа, данной очереди.
2) наличие ответов уже несуществующим потокам.
И то и другое снижает производительность. "Пассажира" конкретно интересует передача объекта потоку. Или, хотя-бы, инициализация переменной, находящейся в потоке. Если такой возможности нет ( как я понял ее нет), лучше так и написать.

Вы невнимательно прочитали общий дизайн вторая должна быть топиком. Если бы Вы были знакомы с концепцией ексченж на RabbitMQ то там есть схема когда очередь открывается по фильтру



авторIn this setup, we can see the direct exchange X with two queues bound to it. The first queue is bound with binding key orange, and the second has two bindings, one with binding key black and the other one with green.

https://www.rabbitmq.com/tutorials/tutorial-four-python.html

Скорее всего такая схема для оповещения продюсера из первой очерди наиболее рабочая, ну или как вариант.

LemkolegSergunka,
Я правильно понимаю: группа очередей, на которые "подписываються" потоки? И получают сообщения из подписанной очереди.

Вам надо уйти от концепции потока. Вам надо понять как строится продьюсер и консьюмер и как работают через топик публикатор и подписчик. В RabbitMQ там есть концепция когда можно через фильтр (exchange) раскидывать сообщения в разные очереди. На самом деле если Вы решите Вашу задачу на уровни концепции через очереди и топики, то дальше можно уже делать на низком уровни через потоки и синхронизацию если это важно в постановке задачи.