Using CountDownLatch for more accurate test result calculation and adding some more tests

Author: arun-gupta

concurrency/managedexecutor/pom.xml

@@ -8,9 +8,6 @@
         <relativePath>../pom.xml</relativePath>
     </parent>
 
-    <groupId>org.javaee7.concurrency</groupId>
     <artifactId>managedexecutor</artifactId>
-    <version>1.0-SNAPSHOT</version>
     <packaging>war</packaging>
-    <name>managedexecutor</name>
 </project>

concurrency/managedexecutor/src/main/java/org/javaee7/concurrency/managedexecutor/ManagedExecutorInEJBServlet.java

@@ -40,8 +40,6 @@
 package org.javaee7.concurrency.managedexecutor;
 
 import java.util.concurrent.Callable;
-import org.javaee7.concurrency.managedexecutor.Product;
-import org.javaee7.concurrency.managedexecutor.Product;
 
 /**
  * @author Arun Gupta
@@ -56,6 +54,7 @@ public MyCallableTask(int id) {
 
     @Override
     public Product call() {
+        TestStatus.latch.countDown();
         return new Product(id);
     }
 }

concurrency/managedexecutor/src/main/java/org/javaee7/concurrency/managedexecutor/MyCallableTask.java

@@ -44,14 +44,8 @@
  */
 public class MyRunnableTask implements Runnable {
 
-    private int id;
-
-    public MyRunnableTask(int id) {
-        this.id = id;
-    }
-
     @Override
     public void run() {
-        TestStatus.invokedRunnable = true;
+        TestStatus.latch.countDown();
     }
 }

concurrency/managedexecutor/src/main/java/org/javaee7/concurrency/managedexecutor/MyRunnableTask.java

@@ -61,8 +61,7 @@ public MyTaskWithListener(int id) {
 
     @Override
     public void run() {
-        TestStatus.invokedTaskWithListener = true;
-        System.out.println("running");
+        TestStatus.latch.countDown();
     }
 
     @Override

concurrency/managedexecutor/src/main/java/org/javaee7/concurrency/managedexecutor/MyTaskWithListener.java

@@ -39,6 +39,8 @@
  */
 package org.javaee7.concurrency.managedexecutor;
 
+import java.util.Objects;
+import javax.inject.Inject;
 import javax.transaction.Transactional;
 
 /**
@@ -47,6 +49,7 @@
 public class MyTaskWithTransaction implements Runnable {
 
     private int id;
+    @Inject MyTransactionScopedBean bean;
 
     public MyTaskWithTransaction() {
     }
@@ -63,11 +66,11 @@ public void setId(int id) {
         this.id = id;
     }
 
-//    @Resource UserTransaction tx;
     @Override
     @Transactional
     public void run() {
-        TestStatus.invokedTaskWithTransaction = true;
+        TestStatus.latch.countDown();
+        TestStatus.foundTransactionScopedBean = Objects.hashCode(bean) != 0;
     }
 
 }

concurrency/managedexecutor/src/main/java/org/javaee7/concurrency/managedexecutor/MyTaskWithTransaction.java

@@ -0,0 +1,8 @@
+package org.javaee7.concurrency.managedexecutor;
+
+/**
+ * @author Arun Gupta
+ */
+@javax.transaction.TransactionScoped
+public class MyTransactionScopedBean {
+}

concurrency/managedexecutor/src/main/java/org/javaee7/concurrency/managedexecutor/MyTransactionScopedBean.java

@@ -39,6 +39,8 @@
  */
 package org.javaee7.concurrency.managedexecutor;
 
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.TimeUnit;
 import javax.annotation.Resource;
 import javax.ejb.Stateless;
 import javax.enterprise.concurrent.ManagedExecutorService;
@@ -51,7 +53,16 @@ public class TestBean {
     @Resource(name = "DefaultManagedExecutorService")
     ManagedExecutorService executor;
 
-    public void run() {
-        executor.submit(new MyRunnableTask(1));
+    public boolean doSomething() throws InterruptedException {
+        TestStatus.latch = new CountDownLatch(1);
+        executor.submit(new Runnable() {
+
+            @Override
+            public void run() {
+                TestStatus.latch.countDown();
+            }
+        });
+        TestStatus.latch.await(2000, TimeUnit.MILLISECONDS);
+        return true;
     }
 }

concurrency/managedexecutor/src/main/java/org/javaee7/concurrency/managedexecutor/TestBean.java

@@ -1,10 +1,11 @@
 package org.javaee7.concurrency.managedexecutor;
 
+import java.util.concurrent.CountDownLatch;
+
 /**
  * @author Arun Gupta
  */
 public class TestStatus {
-    public static boolean invokedRunnable;
-    public static boolean invokedTaskWithListener;
-    public static boolean invokedTaskWithTransaction;
+    public static CountDownLatch latch;
+    public static boolean foundTransactionScopedBean;
 }