Package org.jppf.utils.pooling

Class DirectBufferPoolQueue

java.lang.Object

org.jppf.utils.pooling.AbstractObjectPoolQueue<ByteBuffer>

org.jppf.utils.pooling.DirectBufferPoolQueue

All Implemented Interfaces:

ObjectPool<ByteBuffer>

public class DirectBufferPoolQueue
extends AbstractObjectPoolQueue<ByteBuffer>

A ByteBuffer pool backed by a ConcurrentLinkedQueue.

Author:

Laurent Cohen

Field Summary

Fields inherited from class org.jppf.utils.pooling.AbstractObjectPoolQueue

queue

Constructor Summary

Constructors

Constructor	Description
DirectBufferPoolQueue()

Method Summary

Modifier and Type	Method	Description
protected ByteBuffer	create()	Create a new object for the pool.
DirectBufferPoolQueue	init(int size)	Initialize with size buffers.
void	put(ByteBuffer buffer)	Release an object into this pool, and make it available.

Methods inherited from class org.jppf.utils.pooling.AbstractObjectPoolQueue

createQueue, get, isEmpty, size

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DirectBufferPoolQueue

public DirectBufferPoolQueue()

Method Details

create

protected ByteBuffer create()

Description copied from class: AbstractObjectPoolQueue

Create a new object for the pool.

Specified by:

create in class AbstractObjectPoolQueue<ByteBuffer>

Returns:

an object that can be returned to the pool.

put

public void put(ByteBuffer buffer)

Description copied from interface: ObjectPool

Release an object into this pool, and make it available.

Specified by:

put in interface ObjectPool<ByteBuffer>

Overrides:

put in class AbstractObjectPoolQueue<ByteBuffer>

Parameters:

buffer - the object to release.

init

public DirectBufferPoolQueue init(int size)

Initialize with size buffers.

Parameters:

size - the number of buffers to create.

Returns:

this pool.