1 22 package org.jboss.test.jca.test; 23 24 import javax.resource.cci.Connection ; 25 26 32 public class UncontendedInterleavingStressTestCase extends AbstractUncontendedPoolingStressTest 33 { 34 public void testIt() throws Throwable 35 { 36 tm.setTransactionTimeout(0); 37 UncontendedPoolingRunnable[] runnables = new UncontendedPoolingRunnable[getThreadCount()]; 38 for (int i = 0; i < runnables.length; ++i) 39 { 40 runnables[i] = new UncontendedPoolingRunnable() 41 { 42 public void doRun() throws Throwable 43 { 44 Connection c = cf.getConnection(); 45 c.close(); 46 } 47 }; 48 } 49 50 runConcurrentTest(runnables, null); 51 } 52 53 public UncontendedInterleavingStressTestCase(String name) 54 { 55 super(name); 56 } 57 } 58 | Popular Tags |