com.bigdata.journal

Class StressTestConcurrentTx.Task

java.lang.Object

com.bigdata.journal.StressTestConcurrentTx.Task

All Implemented Interfaces:

Callable<Long>

Enclosing class:

StressTestConcurrentTx

public static class StressTestConcurrentTx.Task
extends Object
implements Callable<Long>

Run a transaction.

Note: defers creation of the tx until it begins to execute! This provides a substantial resource savings and lets transactions begin execution immediately.

Constructor Summary

Constructors

Constructor and Description
StressTestConcurrentTx.Task(Journal journal, String name, int trial, int keyLen, int nops, double abortRate)

Method Summary

Methods

Modifier and Type	Method and Description
Long	call() Executes random operations in the transaction.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

StressTestConcurrentTx.Task

public StressTestConcurrentTx.Task(Journal journal,
                           String name,
                           int trial,
                           int keyLen,
                           int nops,
                           double abortRate)

Method Detail

toString

public String toString()

Overrides:

toString in class Object

call

public Long call()
          throws Exception

Executes random operations in the transaction.

Specified by:

call in interface Callable<Long>

Returns:

The commit time of the transactions and 0L IFF the transaction was aborted.

Throws:

Exception