org.snf4j.core.pool

Interface ISelectorLoopPool

All Known Implementing Classes:

DefaultSelectorLoopPool

public interface ISelectorLoopPool

A base pool for the selector loops

Author:

SNF4J.ORG

Method Summary

Modifier and Type	Method and Description
SelectorLoop	getLoop(SelectableChannel channel) Gets the best selector loop from this pool that should be used to process given channel.
void	join() Waits for all selector loop's threads to die.
boolean	join(long millis) Waits at most millis milliseconds for all selector loop's threads to die.
void	quickStop() Quickly stops all selector loops in this pool.
void	stop() Gently stops all selector loops in this pool.
void	update(SelectorLoop loop, int newSize, int prevSize) Notifies the pool that given selector loop is now processing different number of channels.

Method Detail

stop

void stop()

Gently stops all selector loops in this pool. This operation is asynchronous.

See Also:

InternalSelectorLoop.stop(org.snf4j.core.StoppingType)

quickStop

void quickStop()

Quickly stops all selector loops in this pool. This operation is asynchronous.

See Also:

InternalSelectorLoop.quickStop()

getLoop

SelectorLoop getLoop(SelectableChannel channel)

Gets the best selector loop from this pool that should be used to process given channel.

Parameters:

channel - the channel that needs to be processed by a selector loop form this pool

Returns:

the best selector loop, or null if none could be returned

update

void update(SelectorLoop loop,
            int newSize,
            int prevSize)

Notifies the pool that given selector loop is now processing different number of channels. This method can be used to reorganize the internal structure of the pool to optimize the way the best selector loop is chosen by the getLoop method.

Parameters:

loop - the selector loop

newSize - the new number of channels processed now by the selector loop

prevSize - the previous number of channels processed by the selector loop

join

boolean join(long millis)
      throws InterruptedException

Waits at most millis milliseconds for all selector loop's threads to die.

Parameters:

millis - the time to wait in milliseconds

Returns:

true if the selector loop's thread died

Throws:

InterruptedException - if any thread has interrupted the current thread

IllegalArgumentException - if the value of millis is negative

join

void join()
   throws InterruptedException

Waits for all selector loop's threads to die.

Throws:

InterruptedException - if any thread has interrupted the current thread