Класс AsynchronousChannelGroup

public abstract class AsynchronousChannelGroup
extends Object

Группа асинхронных каналов для совместного использования ресурсов.

Группа асинхронных каналов encapsulates механизмы, необходимые для обработки завершения операций ввода-вывода, инициированных asynchronous channels, привязанными к группе. Группа имеет связанный пул потоков, в который отправляются задачи для обработки событий ввода-вывода и диспетчеризации к completion-handlers, которые потребляют результат асинхронных операций, выполненных над каналами в группе. Помимо обработки событий ввода-вывода, потоки пула могут также выполнять и другие задачи, необходимые для поддержки выполнения асинхронных операций ввода-вывода.

Группа асинхронных каналов создается путем вызова методов withFixedThreadPool или withCachedThreadPool, определенных здесь. Каналы привязываются к группе, указав группу при построении канала. Связанный пул потоков принадлежит группе; завершение группы приводит к завершению связанного пула потоков.

Помимо явно созданных групп, виртуальная машина Java поддерживает группу по умолчанию, которая создается автоматически. Асинхронные каналы, которые не указывают группу при создании, привязываются к группе по умолчанию. Группа по умолчанию имеет связанный пул потоков, который создает новые потоки по мере необходимости. Группу по умолчанию можно настроить с помощью системных свойств, определенных в таблице ниже. Если ThreadFactory для группы по умолчанию не настроен, то потоки пула группы по умолчанию являются daemon потоками.

Системное свойство	Описание
java.nio.channels.DefaultThreadPool.threadFactory	Значение этого свойства принимается как полное имя конкретного класса ThreadFactory. Класс загружается с помощью системного загрузчика классов и создается экземпляр. Метод newThread фабрики вызывается для создания каждого потока для пула потоков группы по умолчанию. Если процесс загрузки и создания экземпляра значения свойства терпит неудачу, при создании группы по умолчанию возникает неопределенная ошибка.
java.nio.channels.DefaultThreadPool.initialSize	Значение параметра initialSize для группы по умолчанию (см. withCachedThreadPool). Значение свойства принимается как строковое представление Integer , представляющее начальный параметр размера. Если значение не может быть обработано как Integer, при создании группы по умолчанию возникает неопределенная ошибка.

Потоки

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

Если операция ввода-вывода завершается немедленно, и инициирующий поток является одним из потоков пула в группе, то обработчик завершения может быть вызван непосредственно инициирующим потоком. Чтобы избежать переполнения стека, реализация может ограничить количество активаций в стеке потока. Некоторые операции ввода-вывода могут запретить вызов обработчика завершения непосредственно инициирующим потоком (см. accept).

Закрытие и завершение

Метод shutdown используется для начала упорядоченного закрытия группы. Упорядоченное закрытие помечает группу как закрытую; дальнейшие попытки создать канал, который привязывается к группе, выбросят ShutdownChannelGroupException. Можно ли проверить, закрыта ли группа, используя метод isShutdown. После закрытия группа завершается, когда все асинхронные каналы, привязанные к группе, закрыты, все активно выполняемые обработчики завершения завершили работу, и ресурсы, используемые группой, освобождены. Не предпринимаются попытки остановить или прервать потоки, которые выполняют обработчики завершения. Метод isTerminated используется для проверки завершения группы, а метод awaitTermination может использоваться для ожидания завершения группы.

Метод shutdownNow можно использовать для инициирования принудительного закрытия группы. В дополнение к действиям, выполняемым при упорядоченном закрытии, метод shutdownNow закрывает все открытые каналы в группе так, как если бы был вызван метод close.

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

AsynchronousChannelGroup

protected AsynchronousChannelGroup(AsynchronousChannelProvider provider)

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

Параметры:

provider - поставщик асинхронного канала для этой группы

Методы

provider

public final AsynchronousChannelProvider provider()

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

Возвращает:

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

withFixedThreadPool

public static AsynchronousChannelGroup withFixedThreadPool(int nThreads,
                                                           ThreadFactory threadFactory)
                                                    throws IOException

Параметры:

nThreads - число потоков в пуле

threadFactory - фабрика для использования при создании новых потоков

Возвращает:

Новую асинхронную группу каналов

Изначает:

IllegalArgumentException - если nThreads <= 0

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

withCachedThreadPool

public static AsynchronousChannelGroup withCachedThreadPool(ExecutorService executor,
                                                            int initialSize)
                                                     throws IOException

Параметры:

executor - пул потоков для результирующей группы

initialSize - значение >=0 или отрицательное значение для реализации специфического значения по умолчанию

Возвращает:

Новую асинхронную группу каналов

Изначает:

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

См. также:

Executors.newCachedThreadPool()

withThreadPool

public static AsynchronousChannelGroup withThreadPool(ExecutorService executor)
                                               throws IOException

Параметры:

executor - пул потоков для результирующей группы

Возвращает:

Новую асинхронную группу каналов

Изначает:

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

isShutdown

public abstract boolean isShutdown()

Указывает, остановлена ли эта асинхронная группа каналов.

Возвращает:

true если эта асинхронная группа каналов остановлена или была помечена на остановку.

isTerminated

public abstract boolean isTerminated()

Возвращает:

true если эта группа завершена

shutdown

public abstract void shutdown()

shutdownNow

public abstract void shutdownNow()
                          throws IOException

Изначает:

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

awaitTermination

public abstract boolean awaitTermination(long timeout,
                                         TimeUnit unit)
                                  throws InterruptedException

Параметры:

timeout - максимальное время ожидания, или ноль или меньше, чтобы не ждать

unit - единица измерения времени аргумента тайм-аута

Возвращает:

true если группа завершена; false если тайм-аут истек до завершения

Изначает:

InterruptedException - если поток был прерван во время ожидания