Каковы хорошие парадигмы параллелизма и инструментальные средства для решения проблем, когда элементы produced с высокой скоростью, processed одновременно и consumed последовательно в одной и той же программе?Без потери данных и без бесконечной памяти.
Я надеюсь на что-то более пригодное для компоновки и повторного использования, чем написать свой собственный, используя Executors и BlockingQueue.