Package dev.getelements.elements.rt

Interface AsyncConnectionPool<ContextT,SocketT>

All Superinterfaces:

AutoCloseable

public interface AsyncConnectionPool<ContextT,SocketT>
extends AutoCloseable

An interface to an underlying pool of sockets.

Method Summary

Modifier and Type	Method	Description
void	acquireNextAvailableConnection(Consumer<AsyncConnection<ContextT,SocketT>> asyncConnectionConsumer)	Acquires a new AsyncConnection.
void	close()	Closes this AsyncConnectionPool<ContextT,SocketT> and releases all AsyncConnection<ContextT,SocketT> resources stored therein.

Method Details

acquireNextAvailableConnection

void acquireNextAvailableConnection(Consumer<AsyncConnection<ContextT,SocketT>> asyncConnectionConsumer)

Acquires a new AsyncConnection. Once assigned to a thread, the supplied Consumer will be called by the IO Thread with an allocated instance of AsyncConnection<ContextT,SocketT>. This method will block until an AsyncConnection is available.

Parameters:

asyncConnectionConsumer - the Consumer which will accept the AsyncConnection<ContextT,SocketT>

close

void close()

Closes this AsyncConnectionPool<ContextT,SocketT> and releases all AsyncConnection<ContextT,SocketT> resources stored therein. Safe to call from any thread.

Specified by:

close in interface AutoCloseable