Класс AbstractInterruptibleChannel

public abstract class AbstractInterruptibleChannel
extends Object
implements Channel, InterruptibleChannel

Базовый реализуемый класс для прерывимых каналов.

Этот класс инкапсулирует низкоуровневые механизмы, необходимые для реализации асинхронного закрытия и прерывания каналов. Конкретный класс канала должен вызвать методы begin и end до и после соответственно вызова операции ввода-вывода, которая может блокироваться неопределенно долго. Для того, чтобы убедиться, что метод end всегда вызывается, эти методы следует использовать в блоке try ... finally:

boolean completed = false;
try {
    begin();
    completed = ...;    // Perform blocking I/O operation
    return ...;         // Return result
} finally {
    end(completed);
}

Аргумент completed метода end указывает, завершилась ли операция ввода-вывода фактически, то есть имела ли она какой-либо эффект, видимый для вызывающего метода. Например, в случае операции чтения байтов этот аргумент должен быть true тогда и только тогда, когда некоторые байты были фактически переданы в буфер вызывающего метода.

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

Этот класс выполняет синхронизацию, необходимую для реализации спецификации Channel. Реализации метода implCloseChannel не нуждаются в синхронизации с другими потоками, которые могут пытаться закрыть канал.

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

AbstractInterruptibleChannel

protected AbstractInterruptibleChannel()

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

Методы

close

public final void close()
                 throws IOException

Указано в:

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

Указано в:

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

Указано в:

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

Указано в:

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

Исключения:

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

implCloseChannel

protected abstract void implCloseChannel()
                                  throws IOException

Исключения:

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

isOpen

public final boolean isOpen()

Описание скопировано из интерфейса: Channel

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

Указано в:

isOpen в интерфейсе Channel

Возвращает:

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

begin

protected final void begin()

end

protected final void end(boolean completed)
                  throws AsynchronousCloseException

Параметры:

completed - true если и только если операция ввода-вывода завершилась успешно, то есть имела какой-либо эффект, видимый для вызывающего метода операции

Исключения:

AsynchronousCloseException - Если канал был асинхронно закрыт

ClosedByInterruptException - Если поток, заблокированный в операции ввода-вывода, был прерван