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

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

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