advanced java multi threading

Author: dheeraj9198

src/CoreJava/advancedMultiThreading/CountDownLatchDemo.java

@@ -0,0 +1,40 @@
+package CoreJava.advancedMultiThreading;
+
+import java.util.concurrent.CountDownLatch;
+
+/**
+ * Created by dheeraj on 7/18/2016.
+ */
+public class CountDownLatchDemo {
+
+    static class Task implements Runnable {
+
+        private CountDownLatch countDownLatch;
+
+        public Task(CountDownLatch countDownLatch) {
+            this.countDownLatch = countDownLatch;
+        }
+
+        @Override
+        public void run() {
+            try {
+                Thread.sleep(3000);
+                countDownLatch.countDown();
+                countDownLatch.await();
+                System.out.println("done waiting " + Thread.currentThread().getName());
+            } catch (Exception e) {
+
+            }
+        }
+    }
+
+    public static void main(String[] strings) {
+        CountDownLatch countDownLatch = new CountDownLatch(3);
+
+        for (int k = 0; k < 3; k++) {
+            Thread thread = new Thread(new Task(countDownLatch));
+            thread.setName("num " + k);
+            thread.start();
+        }
+    }
+}

src/CoreJava/advancedMultiThreading/CyclicBarrierDemo.java

@@ -0,0 +1,44 @@
+package CoreJava.advancedMultiThreading;
+
+import java.util.concurrent.CyclicBarrier;
+
+/**
+ * Created by dheeraj on 7/18/2016.
+ */
+
+public class CyclicBarrierDemo {
+
+    static class Task implements Runnable {
+
+        private CyclicBarrier cyclicBarrier;
+
+        public Task(CyclicBarrier cyclicBarrier) {
+            this.cyclicBarrier = cyclicBarrier;
+        }
+
+        @Override
+        public void run() {
+            try {
+                Thread.sleep(3000);
+                cyclicBarrier.await();
+                System.out.println("done waiting "+Thread.currentThread().getName());
+            } catch (Exception e) {
+
+            }
+        }
+    }
+
+    public static void main(String[] strings){
+        CyclicBarrier cyclicBarrier = new CyclicBarrier(3, new Runnable() {
+            @Override
+            public void run() {
+                System.out.println(Thread.currentThread().getName());
+            }
+        });
+        for(int k=0;k<3;k++){
+            Thread thread = new Thread(new Task(cyclicBarrier));
+            thread.setName("num "+k);
+            thread.start();
+        }
+    }
+}

src/CoreJava/advancedMultiThreading/ProducerConsumer.java

@@ -0,0 +1,71 @@
+package CoreJava.advancedMultiThreading;
+
+import java.util.LinkedList;
+import java.util.Random;
+
+/**
+ * Created by dheeraj on 7/18/2016.
+ */
+public class ProducerConsumer {
+
+    private static final int size = 10;
+    private static LinkedList<Integer> queue = new LinkedList<Integer>();
+    private static Object lock = new Object();
+    private static Random random = new Random();
+
+    static class Producer implements Runnable {
+        @Override
+        public void run() {
+            while (true) {
+                synchronized (lock) {
+                    while (queue.size() == size) {
+                        try {
+                            System.out.println("queue full");
+                            lock.wait();
+                        } catch (Exception e) {
+                            e.printStackTrace();
+                        }
+                    }
+                    queue.add(random.nextInt());
+                    lock.notifyAll();
+                }
+            }
+        }
+    }
+
+    static class Consumer implements Runnable {
+        @Override
+        public void run() {
+            while (true) {
+                try {
+                    Thread.sleep(1000);
+                } catch (Exception e) {
+                }
+                synchronized (lock) {
+                    while (queue.size() == 0) {
+                        try {
+                            lock.wait();
+                        } catch (Exception e) {
+                            e.printStackTrace();
+                        }
+                    }
+                    System.out.println(queue.pollFirst() + " size  = " + queue.size());
+                    lock.notifyAll();
+                }
+            }
+        }
+    }
+
+    public static void main(String[] strings) {
+        new Thread(new Producer()).start();
+        new Thread(new Consumer()).start();
+        new Thread(new Consumer()).start();
+        new Thread(new Consumer()).start();
+        new Thread(new Consumer()).start();
+        new Thread(new Consumer()).start();
+        new Thread(new Consumer()).start();
+
+    }
+
+
+}