Modifier and Type	Class and Description
public static class	XAThreadPool.MultiRunner Pooled thread wrapper which allows reuse of the same thread

Modifier and Type	Field and Description
private final ExecutorService	executor

Access	Constructor and Description
public	XAThreadPool()

Modifier and Type	Method and Description
public synchronized XAThreadPool.MultiRunner	Returns: a MultiRunner which wraps the reserved thread getMultiRunner() Reserve a thread from the pool
public synchronized void	shutdown() Shutdown the thread pool and release all resources

executor	back to summary
private final ExecutorService executor

XAThreadPool	back to summary
public XAThreadPool()

getMultiRunner	back to summary
public synchronized XAThreadPool.MultiRunner getMultiRunner() Reserve a thread from the pool Returns:XAThreadPool.MultiRunner a MultiRunner which wraps the reserved thread

shutdown	back to summary
public synchronized void shutdown() Shutdown the thread pool and release all resources

net.sf.ehcache.transaction.xa.processor back to summary

public final Class XAThreadPool.MultiRunner

Class Inheritance

extends Object
implements Runnable

All Implemented Interfaces

java.lang.Runnable

Pooled thread wrapper which allows reuse of the same thread

Field Summary

Modifier and Type	Field and Description
private volatile Callable<V>	callable
private final CyclicBarrier	endBarrier
private volatile Exception	exception
private volatile boolean	released
private volatile Object	result
private final CyclicBarrier	startBarrier

Access	Constructor and Description
private	MultiRunner()

Modifier and Type	Method and Description
public Object	Returns: the Object returned by the Callable execute(Callable<V> The Callable to execute callable) Execute a Callable on the wrapped thread and return its result
public void	release() Release the wrapped thread back the the containing thread pool
public void	run() Implements java.lang.Runnable.run. Runs this operation.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

callable	back to summary
private volatile Callable<V> callable

endBarrier	back to summary
private final CyclicBarrier endBarrier

exception	back to summary
private volatile Exception exception

released	back to summary
private volatile boolean released

result	back to summary
private volatile Object result

startBarrier	back to summary
private final CyclicBarrier startBarrier

MultiRunner	back to summary
private MultiRunner()

execute	back to summary
public Object execute(Callable<V> callable) throws ExecutionException, InterruptedException Execute a Callable on the wrapped thread and return its result Parameters callable:Callable<V> The Callable to execute Returns:Object the Object returned by the Callable Exceptions ExecutionException: thrown when something went wrong during execution InterruptedException: thrown when the executing thread got interrupted

execute

Execute a Callable on the wrapped thread and return its result

Parameters