commit

Author: aboikliev

week6/1-Multithreading/Core_Java_2_week6/src/com/hackbulgaria/corejava/WaitNotifyMechanism.java

@@ -0,0 +1,66 @@
+package com.hackbulgaria.corejava;
+
+public class WaitNotifyMechanism {
+    public static long startTime = System.currentTimeMillis();
+    public static Integer counter = 0;
+    public static final Object monitor = new Object();
+    private static int turn = 0;
+
+    public static void increment() {
+        System.out.println("Incrementing from Thread : " + Thread.currentThread().getName() + " " + counter );
+        counter++;
+    }
+
+    public static void main(String[] args) throws InterruptedException {
+        Thread t1 = new Thread() {
+            public void run() {
+                for (int i = 0; i < 2_000_000; i++) {
+                    synchronized (monitor) {
+                        while (turn != 1) {
+                            try {
+                                monitor.wait();
+                            } catch (InterruptedException e) {
+                                e.printStackTrace();
+                            }
+
+                        }
+                        increment();
+
+                        turn = (turn + 1) % 2;
+                        monitor.notify();
+                    }
+
+                }
+            }
+        };
+        Thread t2 = new Thread() {
+
+            public void run() {
+                for (int i = 0; i < 2_000_000; i++) {
+                    synchronized (monitor) {
+                        while (turn != 0) {
+                            try {
+                                monitor.wait();
+                            } catch (InterruptedException e) {
+                                e.printStackTrace();
+                            }
+                        }
+
+                        increment();
+
+                        turn = (turn + 1) % 2;
+                        monitor.notify();
+                    }
+                }
+            }
+        };
+        t1.setName("T1");
+        t2.setName("T2");
+        t1.start();
+        t2.start();
+        t1.join();
+        t2.join();
+        System.out.println(counter);
+        System.out.println(System.currentTimeMillis() - startTime);
+    }
+}

week6/1-Multithreading/Core_Java_2_week6/src/week6/task2/producer_consumer/ConsumerThread.java

@@ -0,0 +1,17 @@
+package week6.task2.producer_consumer;
+
+
+public class ConsumerThread implements Runnable {
+	private MyBlockingQueue<String> queue;
+
+	public ConsumerThread(MyBlockingQueue<String> queue) {
+		this.queue = queue;
+	}
+
+	@Override
+	public void run() {
+		while (queue.size() > 0) {
+			queue.poll();
+		}
+	}
+}

week6/1-Multithreading/Core_Java_2_week6/src/week6/task2/producer_consumer/ProducerThread.java

@@ -0,0 +1,18 @@
+package week6.task2.producer_consumer;
+
+public class ProducerThread implements Runnable {
+
+	private MyBlockingQueue<String> queue;
+	public ProducerThread(MyBlockingQueue<String> queue) {
+		this.queue = queue;
+
+	}
+
+	@Override
+	public void run() {
+		for (int i = 1; i < 1001; i++) {
+			queue.add(Thread.currentThread().getName() + ": " + i + " - " + System.nanoTime()
+					% 1_000_000);
+		}
+	}
+}

week6/1-Multithreading/Core_Java_2_week6/src/week6/task2/producer_consumer/ThreadRunner.java

@@ -0,0 +1,38 @@
+package week6.task2.producer_consumer;
+
+public class ThreadRunner {
+	public static void main(String[] args) throws InterruptedException {
+		MyBlockingQueue<String> queue = new MyBlockingQueue<>(100);
+
+		ProducerThread p1 = new ProducerThread(queue);
+		ProducerThread p2 = new ProducerThread(queue);
+		ProducerThread p3 = new ProducerThread(queue);
+
+		ConsumerThread c1 = new ConsumerThread(queue);
+		ConsumerThread c2 = new ConsumerThread(queue);
+
+		Thread t1 = new Thread(p1);
+		t1.setName("producer 1");
+		Thread t2 = new Thread(p2);
+		t2.setName("producer 2");
+		Thread t3 = new Thread(p3);
+		t3.setName("producer 3");
+
+		Thread t4 = new Thread(c1);
+		t4.setName("consumer 1");
+		Thread t5 = new Thread(c2);
+		t5.setName("consumer 2");
+
+		t1.start();
+		t2.start();
+		t3.start();
+		t4.start();
+		t5.start();
+//		t1.join();
+//		t2.join();
+//		t3.join();
+//		t4.join();
+//		t5.join();
+		
+	}
+}