[jboss-cvs] JBossAS SVN: r86531 - in projects/jboss-jca/trunk/core/src/test/java/org/jboss/jca/test/core/spec/chapter10: section3 and 1 other directory.

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

Author: jesper.pedersen
Date: 2009-03-31 09:00:28 -0400 (Tue, 31 Mar 2009)
New Revision: 86531

Modified:
   projects/jboss-jca/trunk/core/src/test/java/org/jboss/jca/test/core/spec/chapter10/common/PriorityWork.java
   projects/jboss-jca/trunk/core/src/test/java/org/jboss/jca/test/core/spec/chapter10/section3/WorkManagementModelTestCase.java
Log:
Fix testAsUseThreadSamePriorityLevel

Modified: projects/jboss-jca/trunk/core/src/test/java/org/jboss/jca/test/core/spec/chapter10/common/PriorityWork.java
===================================================================
--- projects/jboss-jca/trunk/core/src/test/java/org/jboss/jca/test/core/spec/chapter10/common/PriorityWork.java	2009-03-31 12:34:42 UTC (rev 86530)
+++ projects/jboss-jca/trunk/core/src/test/java/org/jboss/jca/test/core/spec/chapter10/common/PriorityWork.java	2009-03-31 13:00:28 UTC (rev 86531)
@@ -21,6 +21,8 @@
  */
 package org.jboss.jca.test.core.spec.chapter10.common;
 
+import java.util.concurrent.CountDownLatch;
+
 import javax.resource.spi.work.Work;
 
 /**
@@ -30,12 +32,15 @@
 public class PriorityWork implements Work
 {
    private int threadPriority;
-   
+   private CountDownLatch done;
+
    /**
     * Constructor.
+    * @param done The done signal count down latch
     */
-   public PriorityWork()
+   public PriorityWork(CountDownLatch done)
    {
+      this.done = done;
    }
    
    /**
@@ -43,7 +48,6 @@
     */
    public void release()
    {
-
    }
 
    /**
@@ -52,6 +56,7 @@
    public void run()
    {
       threadPriority = Thread.currentThread().getPriority();
+      done.countDown();
    }
 
    /**
@@ -62,4 +67,3 @@
       return threadPriority;
    }
 }
-

Modified: projects/jboss-jca/trunk/core/src/test/java/org/jboss/jca/test/core/spec/chapter10/section3/WorkManagementModelTestCase.java
===================================================================
--- projects/jboss-jca/trunk/core/src/test/java/org/jboss/jca/test/core/spec/chapter10/section3/WorkManagementModelTestCase.java	2009-03-31 12:34:42 UTC (rev 86530)
+++ projects/jboss-jca/trunk/core/src/test/java/org/jboss/jca/test/core/spec/chapter10/section3/WorkManagementModelTestCase.java	2009-03-31 13:00:28 UTC (rev 86531)
@@ -256,13 +256,19 @@
       WorkManager workManager = bootstrap.lookup("WorkManager", WorkManager.class);
       
       List<PriorityWork> listWorks = new ArrayList<PriorityWork>();
-      PriorityWork pwork;
-      for (int i = 0; i < 3; i++)
+
+      int number = 3;
+      CountDownLatch done = new CountDownLatch(number);
+
+      for (int i = 0; i < number; i++)
       {
-         pwork = new PriorityWork();
+         PriorityWork pwork = new PriorityWork(done);
          listWorks.add(pwork);
          workManager.doWork(pwork);
       }
+
+      done.await();
+
       int threadPriortity = -1;
       for (PriorityWork work : listWorks)
       {