Class KryoPoolQueueImpl

java.lang.Object

com.esotericsoftware.kryo.pool.KryoPoolQueueImpl

All Implemented Interfaces:

KryoPool

class KryoPoolQueueImpl
extends Object
implements KryoPool

A simple Queue based KryoPool implementation, should be built using the KryoPool.Builder.

Nested Class Summary

Nested classes/interfaces inherited from interface KryoPool

KryoPool.Builder

Field Summary

Fields

Modifier and Type	Field	Description
private final KryoFactory	factory
private final Queue<Kryo>	queue

Constructor Summary

Constructors

Constructor	Description
KryoPoolQueueImpl(KryoFactory factory, Queue<Kryo> queue)

Method Summary

Modifier and Type	Method	Description
Kryo	borrow()	Takes a Kryo instance from the pool or creates a new one (using the factory) if the pool is empty.
void	clear()
void	release(Kryo kryo)	Returns the given Kryo instance to the pool.
<T> T	run(KryoCallback<T> callback)	Runs the provided KryoCallback with a Kryo instance from the pool (borrow/release around KryoCallback.execute(Kryo)).
int	size()

Methods inherited from class Object

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

Field Details

queue

private final Queue<Kryo> queue

factory

private final KryoFactory factory

Constructor Details

KryoPoolQueueImpl

KryoPoolQueueImpl(KryoFactory factory,
 Queue<Kryo> queue)

Method Details

size

public int size()

borrow

public Kryo borrow()

Description copied from interface: KryoPool

Takes a Kryo instance from the pool or creates a new one (using the factory) if the pool is empty.

Specified by:

borrow in interface KryoPool

release

public void release(Kryo kryo)

Description copied from interface: KryoPool

Returns the given Kryo instance to the pool.

Specified by:

release in interface KryoPool

run

public <T> T run(KryoCallback<T> callback)

Description copied from interface: KryoPool

Runs the provided KryoCallback with a Kryo instance from the pool (borrow/release around KryoCallback.execute(Kryo)).

Specified by:

run in interface KryoPool

clear

public void clear()