Await Termination

Author: Rajeev Kumar Singh

java-concurrency-issues-and-synchronization/Readme.md

@@ -1,5 +1,6 @@
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
+import java.util.concurrent.TimeUnit;
 
 /**
  * Created by rajeevkumarsingh on 11/05/17.
@@ -18,7 +19,7 @@ public int getCount() {
 
 public class RaceConditionExample {
 
-    public static void main(String[] args) {
+    public static void main(String[] args) throws InterruptedException {
         ExecutorService executorService = Executors.newFixedThreadPool(10);
 
         Counter counter = new Counter();
@@ -27,6 +28,9 @@ public static void main(String[] args) {
             executorService.submit(() -> counter.increment());
         }
 
+        executorService.shutdown();
+        executorService.awaitTermination(60, TimeUnit.SECONDS);
+
         System.out.println("Final count is : " + counter.getCount());
     }
 }

java-concurrency-issues-and-synchronization/src/RaceConditionExample.java

@@ -1,5 +1,6 @@
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
+import java.util.concurrent.TimeUnit;
 
 /**
  * Created by rajeevkumarsingh on 11/05/17.
@@ -20,14 +21,17 @@ public int getCount() {
 }
 
 public class SynchronizedBlockExample {
-    public static void main(String[] args) {
+    public static void main(String[] args) throws InterruptedException {
         ExecutorService executorService = Executors.newFixedThreadPool(10);
         FineGrainedSynchronizedCounter counter = new FineGrainedSynchronizedCounter();
 
         for(int i = 0; i < 1000; i++) {
             executorService.submit(() -> counter.increment());
         }
 
+        executorService.shutdown();
+        executorService.awaitTermination(60, TimeUnit.SECONDS);
+
         System.out.println("Final count is " + counter.getCount());
     }
 }

java-concurrency-issues-and-synchronization/src/SynchronizedBlockExample.java

@@ -1,5 +1,6 @@
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
+import java.util.concurrent.TimeUnit;
 
 /**
  * Created by rajeevkumarsingh on 11/05/17.
@@ -9,6 +10,7 @@ class SynchronizedCounter {
 
     // Synchronized Method
     public synchronized void increment() {
+	System.out.println(Thread.currentThread().getName());
         count = count + 1;
     }
 
@@ -18,7 +20,7 @@ public int getCount() {
 }
 
 public class SynchronizedMethodExample {
-    public static void main(String[] args) {
+    public static void main(String[] args) throws InterruptedException {
         ExecutorService executorService = Executors.newFixedThreadPool(10);
 
         SynchronizedCounter synchronizedCounter = new SynchronizedCounter();
@@ -27,6 +29,9 @@ public static void main(String[] args) {
             executorService.submit(() -> synchronizedCounter.increment());
         }
 
+        executorService.shutdown();
+        executorService.awaitTermination(60, TimeUnit.SECONDS);
+
         System.out.println("Final count is : " + synchronizedCounter.getCount());
     }
-}
+}