Подкину тему для обсуждения. Возможно, что все тривиально, но когда я недавно решал подобную задачу, пришлось немного почесать репу. До сих пор не уверен, что сделал правильно, поэтому было бы интересно послушать мнения более опытных коллег.
Суть в следующем. Есть поток, который принимает данные с сокетов с помощью java.nio.channels.Selector:
1.
2.
3.
4.
5.
6.
7.
Selector selector = Selector.open();
while (true) {
int n;
while ((n = selector.select()) == 0)
;
// process selector.selectedKeys()
}
Есть многопоточный экзекутор, который выполняет задачи по установке новых коннектов. Несколько коннектов может устанавливаться параллельно. В рамках задачи по установке коннекта производится регистрация SocketChannel в том же самом Selector'е.
Задача заключается вот в чем. Как минимум - никогда не блокироваться на вызове
channel.register() .
Задача максимум - сделать настолько оптимально, насколько это вообще возможно. Под оптимальностью я в данном случае понимаю следующее:
(1) минимизировать время регистрации (параллельно могут устанавливаться сотни коннектов)
(2) минимизировать интервал между операциями select, так как данные с уже установленных коннектов идут интенсивным равномерным потоком
Пункты (1) и (2) одинаково важны, т.е. требуется разумный баланс.
