Класс AsynchronousChannelGroup

protected AsynchronousChannelGroup(AsynchronousChannelProvider provider)

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

public final AsynchronousChannelProvider provider()

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

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

Создаёт группу асинхронных каналов с фиксированным пулом потоков.

Результирующая группа асинхронных каналов повторно использует фиксированное количество потоков. В любой момент времени не более nThreads потоков будут активны в обработке задач, которые переданы для обработки событий ввода-вывода и отправки результатов завершения для операций, инициированных на асинхронных каналах в группе.

Группа создаётся вызовом метода openAsynchronousChannelGroup(int,ThreadFactory) системного по умолчанию AsynchronousChannelProvider объекта.

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

Создаёт группу асинхронных каналов с заданным пулом потоков, который создаёт новые потоки по мере необходимости.

Параметр executor — это ExecutorService, который создаёт новые потоки по мере необходимости для выполнения задач, которые отправляются для обработки событий ввода-вывода и отправки результатов завершения для операций, инициированных на асинхронных каналах в группе. Он может повторно использовать ранее созданные потоки, если они доступны.

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

Исполнитель предназначен для использования исключительно результатом асинхронной группой каналов. Завершение группы приводит к упорядоченному shutdown сервиса выполнения задач. Выключение сервиса выполнения задач другими способами приводит к неопределённому поведению.

Группа создаётся вызовом метода openAsynchronousChannelGroup(ExecutorService,int) системного по умолчанию AsynchronousChannelProvider объекта.

public static AsynchronousChannelGroup withThreadPool(ExecutorService executor) throws IOException

Создаёт группу асинхронных каналов с заданным пулом потоков.

Параметр executor — это ExecutorService, который выполняет задачи, переданные для отправки результатов завершения для операций, инициированных на асинхронных каналах в группе.

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

Исполнитель предназначен для использования исключительно результатом асинхронной группой каналов. Завершение группы приводит к упорядоченному shutdown сервиса выполнения задач. Выключение сервиса выполнения задач другими способами приводит к неопределённому поведению.

Группа создаётся вызовом метода openAsynchronousChannelGroup(ExecutorService,int) системного по умолчанию AsynchronousChannelProvider объекта с initialSize 0.

public abstract boolean isShutdown()

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

public abstract boolean isTerminated()

Указывает, завершена ли эта группа.

Если этот метод возвращает true, то связанный пул потоков также terminated.

public abstract void shutdown()

Инициирует упорядоченное завершение работы группы.

Этот метод помечает группу как завершённую. Дальнейшие попытки создать канал, связанный с этой группой, вызовут ShutdownChannelGroupException. Группа завершается, когда все асинхронные каналы в группе закрыты, все активно выполняющиеся обработчики завершения завершены и все ресурсы освобождены. Этот метод не имеет эффекта, если группа уже остановлена.

public abstract void shutdownNow() throws IOException

Останавливает группу и закрывает все открытые каналы в группе.

Кроме действий, выполняемых методом shutdown, этот метод вызывает метод close для всех открытых каналов в группе. Этот метод не пытается остановить или прервать потоки, которые выполняют обработчики завершения. Группа завершается, когда все активно выполняющиеся обработчики завершения завершены и все ресурсы освобождены. Этот метод может быть вызван в любое время. Если какой-либо другой поток уже вызвал его, то другой вызов будет блокироваться до завершения первого вызова, после чего он вернётся без эффекта.

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

Ожидает завершения работы группы.

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