com.esotericsoftware.kryo.pool

Class KryoPoolQueueImpl

java.lang.Object

com.esotericsoftware.kryo.pool.KryoPoolQueueImpl

All Implemented Interfaces:

KryoPool

class KryoPoolQueueImpl
extends java.lang.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 com.esotericsoftware.kryo.pool.KryoPool

KryoPool.Builder

Field Summary

Fields

Modifier and Type	Field and Description
private KryoFactory	factory
private java.util.Queue<Kryo>	queue

Constructor Summary

Constructors

Constructor and Description
KryoPoolQueueImpl(KryoFactory factory, java.util.Queue<Kryo> queue)

Method Summary

Modifier and Type	Method and 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 java.lang.Object

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

Field Detail

queue

private final java.util.Queue<Kryo> queue

factory

private final KryoFactory factory

Constructor Detail

KryoPoolQueueImpl

KryoPoolQueueImpl(KryoFactory factory,
                  java.util.Queue<Kryo> queue)

Method Detail

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()