put(t0, "row1", "col1", "100");
put(t0, "row2", "col1", "100");
t0.commit();
final CyclicBarrier barrier = new CyclicBarrier(2);
final Transaction t1 = startTransaction();
<BUG>ExecutorService exec = PTExecutors.newCachedThreadPool();

Future<?> f = exec.submit( new Callable<Void>() {
@Override</BUG>
public Void call() throws Exception {

put(t0, "row1", "col1", "100");
put(t0, "row2", "col1", "100");
t0.commit();
Transaction t1 = startTransaction();
Transaction t2 = startTransaction();
