OpenJDK 27 · sun.nio.ch.AsynchronousChannelGroupImpl

Modifier and Type	Field and Description
private static final int	internalThreadCount
private final ThreadPool	pool
private final AtomicBoolean	shutdown
private final Object	shutdownNowLock
private final Queue<Runnable>	taskQueue
private volatile boolean	terminateInitiated
private final AtomicInteger	threadCount
private final ScheduledThreadPoolExecutor	timeoutExecutor

Access	Constructor and Description
pack-priv	AsynchronousChannelGroupImpl(AsynchronousChannelProvider provider, ThreadPool pool)

Method Summary

Modifier and Type	Method and Description
pack-priv abstract Object	attachForeignChannel(Channel channel, FileDescriptor fdo) Attaches a foreign channel to this group.
public final boolean	awaitTermination(long timeout, TimeUnit unit) Implements abstract java.nio.channels.AsynchronousChannelGroup.awaitTermination. Awaits termination of the group.
private Runnable	bindToGroup(final Runnable task)
pack-priv abstract void	closeAllChannels() Closes all channels in the group
pack-priv abstract void	detachForeignChannel(Object key) Detaches a foreign channel from this group.
pack-priv final void	detachFromThreadPool() For use by AsynchronousFileChannel to release resources without shutting down the thread pool.
public final void	execute(Runnable task) Implements java.util.concurrent.Executor.execute. Executes the given command on one of the channel group's pooled threads.
pack-priv abstract void	executeOnHandlerTask(Runnable task) Wakes up a thread waiting for I/O events to execute the given task.
pack-priv final void	executeOnPooledThread(Runnable task) For a fixed thread pool the task is queued to a thread waiting on I/O events.
pack-priv final ExecutorService	executor()
pack-priv final int	fixedThreadCount()
pack-priv abstract boolean	isEmpty() Returns true if there are no channels in the group
pack-priv final boolean	isFixedThreadPool()
public final boolean	isShutdown() Implements abstract java.nio.channels.AsynchronousChannelGroup.isShutdown. Tells whether or not this asynchronous channel group is shutdown.
public final boolean	isTerminated() Implements abstract java.nio.channels.AsynchronousChannelGroup.isTerminated. Tells whether or not this group has terminated.
pack-priv final void	offerTask(Runnable task)
pack-priv final Runnable	pollTask()
pack-priv final Future<?>	schedule(Runnable task, long timeout, TimeUnit unit)
public final void	shutdown() Implements abstract java.nio.channels.AsynchronousChannelGroup.shutdown. Initiates an orderly shutdown of the group.
private void	shutdownExecutors()
pack-priv abstract void	shutdownHandlerTasks() Shutdown all tasks waiting for I/O events.
public final void	shutdownNow() Implements abstract java.nio.channels.AsynchronousChannelGroup.shutdownNow. Shuts down the group and closes all open channels in the group.
private void	startInternalThread(final Runnable task)
protected final void	startThreads(Runnable task)
pack-priv final int	threadCount()
pack-priv final int	threadExit(Runnable task, boolean replaceMe) Invoked by tasks as they terminate

Inherited from java.nio.channels.AsynchronousChannelGroup:: provider withCachedThreadPool withFixedThreadPool withThreadPool

internalThreadCount	back to summary
private static final int internalThreadCount

pool	back to summary
private final ThreadPool pool

shutdown	back to summary
private final AtomicBoolean shutdown

shutdownNowLock	back to summary
private final Object shutdownNowLock

taskQueue	back to summary
private final Queue<Runnable> taskQueue

terminateInitiated	back to summary
private volatile boolean terminateInitiated

threadCount	back to summary
private final AtomicInteger threadCount

timeoutExecutor	back to summary
private final ScheduledThreadPoolExecutor timeoutExecutor

AsynchronousChannelGroupImpl	back to summary
pack-priv AsynchronousChannelGroupImpl(AsynchronousChannelProvider provider, ThreadPool pool)

Method Detail

attachForeignChannel	back to summary
pack-priv abstract Object attachForeignChannel(Channel channel, FileDescriptor fdo) throws IOException Attaches a foreign channel to this group.

awaitTermination	back to summary
public final boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException Implements abstract java.nio.channels.AsynchronousChannelGroup.awaitTermination. Doc from java.nio.channels.AsynchronousChannelGroup.awaitTermination. Awaits termination of the group. This method blocks until the group has terminated, or the timeout occurs, or the current thread is interrupted, whichever happens first. Annotations @Override Exceptions InterruptedException: If interrupted while waiting

awaitTermination

back to summary

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

Implements abstract java.nio.channels.AsynchronousChannelGroup.awaitTermination.

Doc from java.nio.channels.AsynchronousChannelGroup.awaitTermination.

Awaits termination of the group.

This method blocks until the group has terminated, or the timeout occurs, or the current thread is interrupted, whichever happens first.

Annotations

@Override

Exceptions

InterruptedException:: If interrupted while waiting

bindToGroup	back to summary
private Runnable bindToGroup(final Runnable task)

closeAllChannels	back to summary
pack-priv abstract void closeAllChannels() throws IOException Closes all channels in the group

detachForeignChannel	back to summary
pack-priv abstract void detachForeignChannel(Object key) Detaches a foreign channel from this group.

detachFromThreadPool	back to summary
pack-priv final void detachFromThreadPool() For use by AsynchronousFileChannel to release resources without shutting down the thread pool.

execute	back to summary
public final void execute(Runnable task) Implements java.util.concurrent.Executor.execute. Executes the given command on one of the channel group's pooled threads. Annotations @Override

execute

back to summary

public final void execute(Runnable task)

Implements java.util.concurrent.Executor.execute.

Executes the given command on one of the channel group's pooled threads.

Annotations

@Override

executeOnHandlerTask	back to summary
pack-priv abstract void executeOnHandlerTask(Runnable task) Wakes up a thread waiting for I/O events to execute the given task.

executeOnPooledThread	back to summary
pack-priv final void executeOnPooledThread(Runnable task) For a fixed thread pool the task is queued to a thread waiting on I/O events. For other thread pools we simply submit the task to the thread pool.

executor	back to summary
pack-priv final ExecutorService executor()

fixedThreadCount	back to summary
pack-priv final int fixedThreadCount()

isEmpty	back to summary
pack-priv abstract boolean isEmpty() Returns true if there are no channels in the group

isFixedThreadPool	back to summary
pack-priv final boolean isFixedThreadPool()

isShutdown	back to summary
public final boolean isShutdown() Implements abstract java.nio.channels.AsynchronousChannelGroup.isShutdown. Doc from java.nio.channels.AsynchronousChannelGroup.isShutdown. Tells whether or not this asynchronous channel group is shutdown. Annotations @Override

isShutdown

back to summary

public final boolean isShutdown()

Implements abstract java.nio.channels.AsynchronousChannelGroup.isShutdown.

Doc from java.nio.channels.AsynchronousChannelGroup.isShutdown.

Tells whether or not this asynchronous channel group is shutdown.

Annotations

@Override

isTerminated back to summary

isTerminated	back to summary
public final boolean isTerminated() Implements abstract java.nio.channels.AsynchronousChannelGroup.isTerminated. Doc from java.nio.channels.AsynchronousChannelGroup.isTerminated. Tells whether or not this group has terminated. Where this method returns `true`, then the associated thread pool has also `terminated`. Annotations @Override

public final boolean isTerminated()

Implements abstract java.nio.channels.AsynchronousChannelGroup.isTerminated.

Doc from java.nio.channels.AsynchronousChannelGroup.isTerminated.

Tells whether or not this group has terminated.

Where this method returns true, then the associated thread pool has also terminated.

Annotations

@Override

offerTask	back to summary
pack-priv final void offerTask(Runnable task)

pollTask	back to summary
pack-priv final Runnable pollTask()

schedule	back to summary
pack-priv final Future<?> schedule(Runnable task, long timeout, TimeUnit unit)

shutdown back to summary

shutdown	back to summary
public final void shutdown() Implements abstract java.nio.channels.AsynchronousChannelGroup.shutdown. Doc from java.nio.channels.AsynchronousChannelGroup.shutdown. Initiates an orderly shutdown of the group. This method marks the group as shutdown. Further attempts to construct channel that binds to this group will throw `ShutdownChannelGroupException`. The group terminates when all asynchronous channels in the group are closed, all actively executing completion handlers have run to completion, and all resources have been released. This method has no effect if the group is already shutdown. Annotations @Override

public final void shutdown()

Implements abstract java.nio.channels.AsynchronousChannelGroup.shutdown.

Doc from java.nio.channels.AsynchronousChannelGroup.shutdown.

Initiates an orderly shutdown of the group.

This method marks the group as shutdown. Further attempts to construct channel that binds to this group will throw ShutdownChannelGroupException. The group terminates when all asynchronous channels in the group are closed, all actively executing completion handlers have run to completion, and all resources have been released. This method has no effect if the group is already shutdown.

Annotations

@Override

shutdownExecutors	back to summary
private void shutdownExecutors()

shutdownHandlerTasks	back to summary
pack-priv abstract void shutdownHandlerTasks() Shutdown all tasks waiting for I/O events.

shutdownNow back to summary

shutdownNow	back to summary
public final void shutdownNow() throws IOException Implements abstract java.nio.channels.AsynchronousChannelGroup.shutdownNow. Doc from java.nio.channels.AsynchronousChannelGroup.shutdownNow. Shuts down the group and closes all open channels in the group. In addition to the actions performed by the `shutdown` method, this method invokes the `close` method on all open channels in the group. This method does not attempt to stop or interrupt threads that are executing completion handlers. The group terminates when all actively executing completion handlers have run to completion and all resources have been released. This method may be invoked at any time. If some other thread has already invoked it, then another invocation will block until the first invocation is complete, after which it will return without effect. Annotations @Override Exceptions IOException: If an I/O error occurs

public final void shutdownNow() throws IOException

Implements abstract java.nio.channels.AsynchronousChannelGroup.shutdownNow.

Doc from java.nio.channels.AsynchronousChannelGroup.shutdownNow.

Shuts down the group and closes all open channels in the group.

In addition to the actions performed by the shutdown method, this method invokes the close method on all open channels in the group. This method does not attempt to stop or interrupt threads that are executing completion handlers. The group terminates when all actively executing completion handlers have run to completion and all resources have been released. This method may be invoked at any time. If some other thread has already invoked it, then another invocation will block until the first invocation is complete, after which it will return without effect.

Annotations

@Override

Exceptions

IOException:: If an I/O error occurs

startInternalThread	back to summary
private void startInternalThread(final Runnable task)

startThreads	back to summary
protected final void startThreads(Runnable task)

threadCount	back to summary
pack-priv final int threadCount()

threadExit	back to summary
pack-priv final int threadExit(Runnable task, boolean replaceMe) Invoked by tasks as they terminate

pack-priv abstract Class AsynchronousChannelGroupImpl

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail