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

Суть в следующем. Есть поток, который принимает данные с сокетов с помощью java.nio.channels.Selector:



Есть многопоточный экзекутор, который выполняет задачи по установке новых коннектов. Несколько коннектов может устанавливаться параллельно. В рамках задачи по установке коннекта производится регистрация SocketChannel в том же самом Selector'е.

Задача заключается вот в чем. Как минимум - никогда не блокироваться на вызове channel.register() .

Задача максимум - сделать настолько оптимально, насколько это вообще возможно. Под оптимальностью я в данном случае понимаю следующее:
(1) минимизировать время регистрации (параллельно могут устанавливаться сотни коннектов)
(2) минимизировать интервал между операциями select, так как данные с уже установленных коннектов идут интенсивным равномерным потоком
Пункты (1) и (2) одинаково важны, т.е. требуется разумный баланс.

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

Ну и естественно все это находится в разных классах, которые друг про друга ничего не знают. Единственное, что у них изначально есть общее - это Selector. Но при этом допускается использовать общую dependency (например, всунуть в конструктор обоим классам еще какой-то класс).

maytonAndrei T, у тебя есть модульный тест на это дело?
Именно модульного нет. Есть интеграционные на все вместе. Ну и профилирование, конечно.