[jboss-svn-commits] JBL Code SVN: r27834 - labs/jbosstm/trunk/ArjunaJTS/jtax/tests/classes/com/hp/mwtests/ts/jta/jts/basic.

[jboss-svn-commits at lists.jboss.org]

Author: mark.little at jboss.com
Date: 2009-07-10 08:58:05 -0400 (Fri, 10 Jul 2009)
New Revision: 27834

Modified:
   labs/jbosstm/trunk/ArjunaJTS/jtax/tests/classes/com/hp/mwtests/ts/jta/jts/basic/ThreadedCommit.java
Log:
https://jira.jboss.org/jira/browse/JBTM-576

Modified: labs/jbosstm/trunk/ArjunaJTS/jtax/tests/classes/com/hp/mwtests/ts/jta/jts/basic/ThreadedCommit.java
===================================================================
--- labs/jbosstm/trunk/ArjunaJTS/jtax/tests/classes/com/hp/mwtests/ts/jta/jts/basic/ThreadedCommit.java	2009-07-10 12:52:20 UTC (rev 27833)
+++ labs/jbosstm/trunk/ArjunaJTS/jtax/tests/classes/com/hp/mwtests/ts/jta/jts/basic/ThreadedCommit.java	2009-07-10 12:58:05 UTC (rev 27834)
@@ -46,11 +46,11 @@
 
 class TWorker extends Thread
 {
-    public TWorker (javax.transaction.Transaction tx, boolean first)
+    public TWorker (javax.transaction.Transaction tx, TWorker driver)
     {
         _tx = tx;
         _success = true;
-        _first = first;
+        _driver = driver;
     }
 
     public void run ()
@@ -61,18 +61,15 @@
         {
             tm.resume(_tx);
 
-            if (!_first)
+            if (_driver != null)
             {
-                while (tm.getStatus() == Status.STATUS_ACTIVE)
+                try
                 {
-                    try
-                    {
-                        Thread.sleep(1000);
-                    }
-                    catch (final Exception ex)
-                    {
-                    }
+                    _driver.join();
                 }
+                catch (final Exception ex)
+                {
+                }
             }
 
             tm.commit();
@@ -92,7 +89,7 @@
 
     private Transaction _tx;
     private boolean _success;
-    private boolean _first;
+    private TWorker _driver;
 }
 
 public class ThreadedCommit
@@ -130,14 +127,13 @@
 
             tm.begin();
 
-            javax.transaction.Transaction theTransaction = tm
-                    .getTransaction();
+            javax.transaction.Transaction theTransaction = tm.suspend();
 
-            TWorker worker1 = new TWorker(theTransaction, true);
-            TWorker worker2 = new TWorker(theTransaction, false);
+            TWorker worker1 = new TWorker(theTransaction, null);
+            TWorker worker2 = new TWorker(theTransaction, worker1);
 
-            worker1.start();
             worker2.start();
+            worker1.start();
 
             worker1.join();
             worker2.join();