distribute tests in parallel ...

Author: sunilpatro1985

pom.xml

@@ -126,7 +126,7 @@
                         <include>src/test/parallel_distribute/*</include>
                     </includes-->
                     <parallel>classes</parallel>
-                    <threadCount>2</threadCount>
+                    <threadCount>3</threadCount>
                     <skipTests>${skipTests}</skipTests>
                 </configuration>
             </plugin>

src/main/java/base/Utility.java

@@ -0,0 +1,13 @@
+package base;
+
+import java.text.SimpleDateFormat;
+import java.util.Date;
+
+public class Utility {
+
+    public void printCurrentDateTime(){
+        SimpleDateFormat formatter = new SimpleDateFormat("dd/MM/yyyy HH:mm:ss");
+        Date date = new Date();
+        System.out.println(formatter.format(date));
+    }
+}

src/test/java/parallel_distribute/BaseTestNG.java

@@ -0,0 +1,16 @@
+package parallel_distribute;
+
+import base.Utility;
+import org.testng.annotations.AfterSuite;
+import org.testng.annotations.BeforeSuite;
+
+public class BaseTestNG {
+    @BeforeSuite
+    public void setUp(){
+        new Utility().printCurrentDateTime();
+    }
+    @AfterSuite
+    public void tearDown(){
+        new Utility().printCurrentDateTime();
+    }
+}

src/test/java/parallel_distribute/TestNG1.java

@@ -1,21 +1,26 @@
 package parallel_distribute;
 
+import base.Utility;
 import org.testng.annotations.Test;
 
-public class TestNG1 {
-    //@Test
+import java.text.SimpleDateFormat;
+import java.util.Date;
+
+public class TestNG1 extends BaseTestNG{
+    @Test
     public void TestNG1_Test1(){
         System.out.println("TestNG1_Test1");
         System.out.println(Thread.currentThread().getId());
     }
 
-    //@Test
-    public void TestNG1_Test2(){
+    @Test
+    public void TestNG1_Test2() throws InterruptedException {
         System.out.println("TestNG1_Test2");
+        Thread.sleep(2000);
         System.out.println(Thread.currentThread().getId());
     }
 
-    //@Test
+    @Test
     public void TestNG1_Test3(){
         System.out.println("TestNG1_Test3");
         System.out.println(Thread.currentThread().getId());

src/test/java/parallel_distribute/TestNG2.java

@@ -2,18 +2,19 @@
 
 import org.testng.annotations.Test;
 
-public class TestNG2 {
-    //@Test
+public class TestNG2 extends BaseTestNG{
+    @Test
     public void TestNG2_Test1(){
         System.out.println("TestNG2_Test1");
         System.out.println(Thread.currentThread().getId());
     }
-    //@Test
-    public void TestNG2_Test2(){
+    @Test
+    public void TestNG2_Test2() throws InterruptedException {
         System.out.println("TestNG2_Test2");
+        Thread.sleep(2000);
         System.out.println(Thread.currentThread().getId());
     }
-    //@Test
+    @Test
     public void TestNG2_Test3(){
         System.out.println("TestNG2_Test3");
         System.out.println(Thread.currentThread().getId());

src/test/java/parallel_distribute/TestNG3.java

@@ -1,21 +1,24 @@
 package parallel_distribute;
 
+import base.Utility;
 import org.testng.annotations.Test;
 
-public class TestNG3 {
-    //@Test
+public class TestNG3 extends BaseTestNG{
+    @Test
     public void TestNG2_Test1(){
         System.out.println("TestNG2_Test1");
         System.out.println(Thread.currentThread().getId());
     }
-    //@Test
-    public void TestNG2_Test2(){
+    @Test
+    public void TestNG2_Test2() throws InterruptedException {
         System.out.println("TestNG2_Test2");
+        Thread.sleep(2000);
         System.out.println(Thread.currentThread().getId());
     }
-    //@Test
+    @Test
     public void TestNG2_Test3(){
         System.out.println("TestNG2_Test3");
         System.out.println(Thread.currentThread().getId());
+        new Utility().printCurrentDateTime();
     }
 }

src/test/java/testCases/TestLogin.java

@@ -18,7 +18,7 @@
 public class TestLogin extends BaseTest {
     WebDriverWait wait;
 
-    @Test
+    //@Test
     public void MavenParamTest() throws InterruptedException {
         System.out.println(Thread.currentThread().getId());
         //WebDriver driver = PageDriver.getCurrentDriver();

src/test/java/testCases/TestLogin_invalid.java

@@ -15,7 +15,7 @@
 public class TestLogin_invalid extends BaseTest {
     WebDriverWait wait;
 
-    @Test
+    //@Test
     public void MavenParamTest() throws InterruptedException {
         System.out.println(Thread.currentThread().getId());
 

src/test/java/testCases/TestProductItems.java

@@ -14,7 +14,7 @@
 public class TestProductItems extends BaseTest {
     WebDriverWait wait;
 
-    @Test
+    //@Test
     public void Test_TestProductItems() throws Exception {
         System.out.println(Thread.currentThread().getId());