Класс 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

Закрывает этот канал.

Если канал уже закрыт, то этот метод возвращается немедленно. В противном случае он помечает канал как закрытый, а затем вызывает метод implCloseChannel для завершения операции закрытия.

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

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

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

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

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

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

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

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

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

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

implCloseChannel

protected abstract void implCloseChannel()
                                  throws IOException

Закрывает этот канал.

Этот метод вызывается методом close для выполнения фактической работы по закрытию канала. Этот метод вызывается только в том случае, если канал ещё не закрыт, и он никогда не вызывается более одного раза.

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

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

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

begin

protected final void begin()

Помечает начало операции ввода-вывода, которая может блокироваться неопределённо долго.

Этот метод должен вызываться совместно с методом end, используя блок try ... finally, как показано выше, для реализации асинхронного закрытия и прерывания для этого канала.

end

protected final void end(boolean completed)
                  throws AsynchronousCloseException

Помечает конец операции ввода-вывода, которая может блокироваться неопределённо долго.

Этот метод должен вызываться совместно с методом begin, используя блок try ... finally, как показано выше, для реализации асинхронного закрытия и прерывания для этого канала.

Параметры:

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

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

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

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