Два потока, две очереди, два потока

Есть две очереди. Каждая из них заполняется своим потоком. Есть два потока, которые достают данные из своей очереди. Но когда одна из очередей становится больше заданного размера n, то есть поток достающий данные из этой очереди не справляется, на помощь должен придти достающий поток соседней очереди, но только при условии, что у него со своей очередью все хорошо.
Мне не понятно, как сообщить соседнему достающему потоку, что:"вот мол, помоги мне, я не справляюсь со своей очередью".
Пока что есть только потокобезопасная очередь.

0

А сообщать не надо. Просто поток должен смотреть на состояние и своей очереди, и соседней. Если своя почти пустая, то заняться соседней. Очередь потокобезопасна, поэтому всё будет хорошо.

0

Сообщение от cordfield заняться соседней

заняться соседней нужно когда там проблемы(когда длинная очередь), а не когда своя очередь пуста.
Сделал в принципе так. Работает. Но вопрос, как теперь остановить потоки потребители? Потоки производители то остановились сами собой, когда добавили n-ое количество элементов. А потоки потребители?
Наверное самым оптимальным решением будет завести в очереди флаг. Когда производители завершат добавлять элементы, изменить значение флага, и потребители будут знать, что новых элементов не будет. Им останется только обработать оставшиеся элементы.

0

Сообщение от vab9petryk Мне не понятно, как сообщить соседнему достающему потоку, что:"вот мол, помоги мне, я не справляюсь со своей очередью".

есть тред-пул.
он держит открытыми, но спящими несколько штук потоков
(по количеству ядер процессора обычно).

клиент грузит пул задачами.
может быть 1 штуку,
может быть сразу 1000 штук.

задачи падают во внутреннию очередь пула.
что приводит к сигналу, и один из потоков пробуждается.

поток копирует к себе кучку задач.
если их слишком много: делает сигнал, что приводит к пробуждению ещё одного потока.

ещё один поток копирует к себе кучку задач.
если их слишком много: делает сигнал... (ну вы поняли).

если все потоки уже пробудулись,
но все задачи растащить не смогли,
тогда избыток так и остается валяться в очереди,
и ждать своего часа.

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

если там пусто - засыпает.
но если там что то есть, поток копирует к себе очередную кучку задач.
если их слишком много:
делает сигнал, что приводит к пробуждению ещё одного потока.
(ну вы поняли)

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

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

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

поэтому, пока в очереди есть хотя бы одна задачка,
гарантируется, что всегда будет хотя бы один не спящий поток,
который её захавает.

1

0