Класс Selector

public abstract class Selector
extends Object
implements Closeable

Мультиплексор объектов SelectableChannel.

Селектор может быть создан путём вызова метода open этого класса, который будет использовать системный по умолчанию selector provider для создания нового селектора. Селектор также может быть создан путём вызова метода openSelector пользовательского поставщика селекторов. Селектор остаётся открытым до его закрытия посредством метода close.

Регистрация каналов выбора с селектором представлена объектом SelectionKey. Селектор поддерживает три набора ключей выбора:

• Набор ключей содержит ключи, представляющие текущие регистрации каналов этого селектора. Этот набор возвращается методом keys.

• Набор выбранных ключей — это набор ключей, для каналов каждого ключа было обнаружено, что они готовы хотя бы к одной из операций, определённых в наборе интересов ключа во время предыдущей операции выбора. Этот набор возвращается методом selectedKeys. Набор выбранных ключей всегда является подмножеством набора ключей.

• Набор отменённых ключей — это набор ключей, которые были отменены, но каналы которых ещё не были дерегистрированы. Этот набор не доступен напрямую. Набор отменённых ключей всегда является подмножеством набора ключей.

Все три набора пусты в только что созданном селекторе.

Ключ добавляется в набор ключей селектора как побочный эффект регистрации канала через метод канала register. Отменённые ключи удаляются из набора ключей во время операций выбора. Сам набор ключей непосредственно не изменяем.

Ключ добавляется в набор отменённых ключей селектора, когда он отменяется, независимо от того, закрывается ли его канал или вызывается метод cancel. Отмена ключа приведёт к дерегистрации его канала во время следующей операции выбора, после чего ключ будет удалён из всех наборов ключей селектора.

Ключи добавляются в набор выбранных ключей операциями выбора. Ключ может быть удалён непосредственно из набора выбранных ключей путём вызова метода набора remove или путём вызова метода remove итератора iterator, полученного из набора. Ключи никогда не удаляются из набора выбранных ключей каким-либо другим способом; они не удаляются, в частности, как побочный эффект операций выбора. Ключи нельзя напрямую добавлять в набор выбранных ключей.

Выбор

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

1. Каждый ключ в наборе отменённых ключей удаляется из каждого набора ключей, членом которого он является, и его канал дерегистрируется. Этот шаг оставляет набор отменённых ключей пустым.

2. Базовая операционная система запрашивается об обновлении готовности каждого оставшегося канала к выполнению любой из операций, указанных набором интересов его ключа, начиная с момента начала операции выбора. Для канала, готового хотя бы к одной такой операции, выполняется одно из следующих двух действий:

   1. Если ключ канала ещё не находится в наборе выбранных ключей, то он добавляется в этот набор, и его набор готовых операций изменяется для указания именно тех операций, для которых канал сейчас готов. Любая информация о готовности, ранее записанная в наборе, отбрасывается.

   2. В противном случае ключ канала уже находится в наборе выбранных ключей, поэтому его набор готовых операций изменяется для указания любых новых операций, для которых канал готов. Любая информация о готовности, ранее записанная в наборе, сохраняется; другими словами, набор готовности, возвращаемый базовой системой, побитово дизъюнктивно объединяется с текущим набором готовности ключа.

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

3. Если в набор отменённых ключей были добавлены какие-либо ключи во время выполнения шага (2), то они обрабатываются, как в шаге (1).

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

Конкурентность

Селекторы сами по себе безопасны для использования несколькими потоками; однако их наборы ключей — нет.

Операции выбора синхронизируются на самом селекторе, на наборе ключей и на наборе выбранных ключей в указанном порядке. Они также синхронизируются на наборе отменённых ключей во время шагов (1) и (3) выше.

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

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

Поток, заблокированный в одном из методов select() или select(long), может быть прерван другим потоком тремя способами:

• Путем вызова метода wakeup селектора,

• Путем вызова метода close селектора, или

• Путем вызова метода interrupt заблокированного потока, в этом случае статус прерывания будет установлен, и вызывается метод селектора wakeup.

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

Наборы ключей и выбранных ключей селектора, как правило, не безопасны для одновременного использования несколькими потоками. Если такой поток может непосредственно изменить один из этих наборов, то доступ должен контролироваться синхронизацией на самом наборе. Итераторы, возвращаемые методами iterator этих наборов, являются быстро меняющимися: если набор изменяется после создания итератора каким-либо способом, кроме вызова метода remove самого итератора, то будет брошено исключение ConcurrentModificationException.

Конструкторы

Selector

protected Selector()

Инициализирует новый экземпляр этого класса.

Методы

open

public static Selector open()
                     throws IOException

Возвращает:

Новый селектор

Выбрасывает:

IOException - Если произошла ошибка ввода-вывода

isOpen

public abstract boolean isOpen()

Указывает, открыт ли этот селектор.

Возвращает:

true если и только если этот селектор открыт

provider

public abstract SelectorProvider provider()

Возвращает поставщика, который создал этот канал.

Возвращает:

Поставщик, который создал этот канал

keys

public abstract Set<SelectionKey> keys()

Возвращает:

Набор ключей этого селектора

Выбрасывает:

ClosedSelectorException - Если этот селектор закрыт

selectedKeys

public abstract Set<SelectionKey> selectedKeys()

Возвращает:

Набор выбранных ключей этого селектора

Выбрасывает:

ClosedSelectorException - Если этот селектор закрыт

selectNow

public abstract int selectNow()
                       throws IOException

Возвращает:

Количество ключей, возможно ноль, наборы готовых операций которых были обновлены операцией выбора

Выбрасывает:

IOException - Если произошла ошибка ввода-вывода

ClosedSelectorException - Если этот селектор закрыт

select

public abstract int select(long timeout)
                    throws IOException

Параметры:

timeout - Если положительное, блокировать до timeout миллисекунд, приблизительно, ожидая, пока канал не станет готовым; если ноль, блокировать неопределенно; не должно быть отрицательным

Возвращает:

Количество ключей, возможно ноль, наборы готовых операций которых были обновлены

Выбрасывает:

IOException - Если произошла ошибка ввода-вывода

ClosedSelectorException - Если этот селектор закрыт

IllegalArgumentException - Если значение аргумента таймаута отрицательное

select

public abstract int select()
                    throws IOException

Возвращает:

Количество ключей, возможно ноль, наборы готовых операций которых были обновлены

Выбрасывает:

IOException - Если произошла ошибка ввода-вывода

ClosedSelectorException - Если этот селектор закрыт

wakeup

public abstract Selector wakeup()

Возвращает:

Этот селектор

close

public abstract void close()
                    throws IOException

Определено в:

close в интерфейсе Closeable

Определено в:

close в интерфейсе AutoCloseable

Выбрасывает:

IOException - Если произошла ошибка ввода-вывода