org.opendaylight.vtn.manager.internal.util.tx

Class TxQueueImpl

java.lang.Object

org.opendaylight.vtn.manager.internal.util.tx.TxQueueImpl

All Implemented Interfaces:

AutoCloseable, Runnable, TxQueue

public final class TxQueueImpl
extends Object
implements TxQueue, Runnable, AutoCloseable

Implementation of TxQueue.

MD-SAL datastore transaction may fail if the same data tree is modified by multiple transactions concurrently. This class is used to serialize modification to the same MD-SAL data tree. An instance of this class has a single transaction queue and runner thread. Queued transactions are executed sequentially on the runner thread.

See Also:

TxTask

Constructor Summary

Constructors

Constructor and Description
TxQueueImpl(String name, VTNManagerProvider provider) Construct a new instance.

Method Summary

Modifier and Type	Method and Description
void	close() Close this transaction queue.
<T> VTNFuture<T>	post(TxTask<T> task) Post a new transaction.
<T> VTNFuture<T>	postFirst(TxTask<T> task) Post a new transaction.
void	run() Main routine of the runner thread.
void	start() Start the transaction queue processing.

Methods inherited from class java.lang.Object

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

Constructor Detail

TxQueueImpl

public TxQueueImpl(String name,
                   VTNManagerProvider provider)

Construct a new instance.

Parameters:

name - The name of this queue.

provider - A VTNManagerProvider service instance.

Method Detail

start

public void start()

Start the transaction queue processing.

post

public <T> VTNFuture<T> post(TxTask<T> task)

Post a new transaction.

Specified by:

post in interface TxQueue

Type Parameters:

T - The type of the object to be returned by the task.

Parameters:

task - A TxTask instance.

Returns:

A VTNFuture instance that returns the result of the task.

postFirst

public <T> VTNFuture<T> postFirst(TxTask<T> task)

Post a new transaction.

This method put the given task at the head of the transaction queue.

Specified by:

postFirst in interface TxQueue

Type Parameters:

T - The type of the object to be returned by the task.

Parameters:

task - A TxTask instance.

Returns:

A VTNFuture instance that returns the result of the task.

close

public void close()

Close this transaction queue.

Specified by:

close in interface AutoCloseable

run

public void run()

Main routine of the runner thread.

Specified by:

run in interface Runnable