Add files via upload

Author: davidjava1991

Class16/bin/com/david/class161/Example1.class

@@ -0,0 +1,11 @@
+package com.david.class161;
+
+public class Example1 {
+	public static void main(String[] args) {
+		Runnable r = ()-> System.out.println("Thread started");
+		Thread t1 = new Thread(r);
+		t1.start();
+		Thread t2 = new Thread(r);
+		t2.start();
+	}
+}

Class16/bin/com/david/class161/MyThread.class

@@ -0,0 +1,14 @@
+package com.david.class161;
+
+public class MyThread extends Thread{
+	@Override
+	public void run() {
+		System.out.println("Thread started");
+	}
+	public static void main(String[] args) {
+		MyThread t1 = new MyThread();
+		t1.start();
+		MyThread t2 = new MyThread();
+		t2.start();
+	}
+}

Class16/bin/com/david/class162/JoinThread.class

@@ -0,0 +1,32 @@
+package com.david.class162;
+
+public class JoinThread extends Thread{
+	@Override
+	public void run() {
+		System.out.println("Thread started");
+		for(int i =1; i<5;i++) {
+			try {
+				Thread.sleep(500);
+			} catch (InterruptedException e) {
+				e.printStackTrace();
+			}  
+			System.out.println(i);
+		}
+		System.out.println("Thread ended");
+	}
+	
+	public static void main(String[] args) {
+		JoinThread t1 = new JoinThread();
+		JoinThread t2 = new JoinThread();
+		JoinThread t3 = new JoinThread();
+		t1.start();
+		try {
+			t1.join();
+		} catch (InterruptedException e) {
+			e.printStackTrace();
+		}
+		t2.start();
+		t3.start();
+		
+	}
+}

Class16/bin/com/david/class162/MyThread.class

@@ -0,0 +1,17 @@
+package com.david.class162;
+
+public class MyThread extends Thread{
+	@Override
+	public void run() {
+		System.out.println("MyThread Started");
+	}
+	
+	public static void main(String[] args) {
+		MyThread m = new MyThread();
+		 System.out.println("id : "+m.getId());
+		 System.out.println("name : "+m.getName());
+		 System.out.println("priority : "+m.getPriority());
+		 System.out.println("Current thread name : "+currentThread().getName());
+		 System.out.println("is Daemon : "+m.isDaemon());
+	}
+}

Class16/bin/com/david/class163/Counter.class

@@ -0,0 +1,16 @@
+package com.david.class163;
+
+public class Counter {
+	synchronized void count(int n){
+		for(int i =1;i<n;i++){
+			System.out.println("i = "+i);
+			 try {  
+			      Thread.sleep(100);  
+			  }catch(Exception e){
+				  System.out.println(e);  
+			   } 
+		}
+			
+		
+	}
+}

Class16/bin/com/david/class163/Example1.class

@@ -0,0 +1,9 @@
+package com.david.class163;
+
+public class Example1 {
+	public static void main(String[] args) {
+		Counter c= new Counter();
+		new MyThread1(c).start();
+		new MyThread2(c).start();
+	}
+}

Class16/bin/com/david/class163/MyThread1.class

@@ -0,0 +1,15 @@
+package com.david.class163;
+
+public class MyThread1 extends Thread{
+	Counter counter;
+	public MyThread1(Counter c) {
+		this.counter = c;
+	}
+	@Override
+	public void run() {
+		counter.count(10);
+	}
+		
+	
+	
+}

Class16/bin/com/david/class163/MyThread2.class

@@ -0,0 +1,13 @@
+package com.david.class163;
+
+public class MyThread2 extends Thread{
+	Counter counter;
+	public MyThread2(Counter c) {
+		this.counter = c;
+	}
+	@Override
+	public void run() {
+		counter.count(20);
+	}
+
+}

Class16/bin/com/david/class164/EmployeeThread.class

@@ -0,0 +1,19 @@
+package com.david.class164;
+
+public class EmployeeThread implements Runnable{
+	private String  name;
+	public EmployeeThread(String name) {
+		this.name =name;
+	}
+	@Override
+	public void run() {
+		System.out.println(" Thread "+Thread.currentThread().getId()+" started");
+		System.out.println("name = "+ this.name);;
+		try {
+			Thread.sleep(100);
+		} catch (InterruptedException e) {
+			e.printStackTrace();
+		}	
+	}
+
+}

Class16/bin/com/david/class164/Example1.class

@@ -0,0 +1,16 @@
+package com.david.class164;
+
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+
+public class Example1 {
+	public static void main(String[] args) {
+		 ExecutorService executor = Executors.newFixedThreadPool(3);
+		 String[] names = {"David","Paul","Sam","Adam", "Ben"};
+		 for(String name : names) {
+			 Runnable eThread = new EmployeeThread(name);
+			 executor.execute(eThread);
+		 }
+		 executor.shutdown();
+	}
+}

Class16/bin/com/david/class165/Example1.class

@@ -0,0 +1,30 @@
+package com.david.class165;
+
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.Executors;
+import java.util.concurrent.Future;
+import java.util.concurrent.ThreadPoolExecutor;
+
+public class Example1 {
+	public static void main(String[] args) {
+		ThreadPoolExecutor executor =  (ThreadPoolExecutor) Executors.newFixedThreadPool(2);
+		Future<String> s1 = executor.submit(() -> {
+			System.out.println("Thread1 started");
+		    Thread.sleep(500);
+		    return "task1 done";
+		});
+		Future<String> s2 = executor.submit(() -> {
+			System.out.println("Thread2 started");
+		    Thread.sleep(500);
+		    return "task2 done";
+		});
+		System.out.println("Pool size : "+executor.getPoolSize());
+		System.out.println("Queue size : "+executor.getQueue().size());
+		try {
+			System.out.println(s1.get());
+			System.out.println(s2.get());
+		} catch (InterruptedException | ExecutionException e) {
+			e.printStackTrace();
+		}
+	}
+}

Class16/bin/com/david/class165/Example2.class

@@ -0,0 +1,27 @@
+package com.david.class165;
+
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.Executors;
+import java.util.concurrent.Future;
+import java.util.concurrent.ThreadPoolExecutor;
+
+public class Example2 {
+	public static void main(String[] args) {
+		ThreadPoolExecutor executor = (ThreadPoolExecutor) Executors.newCachedThreadPool();
+		Future<String> op1 = executor.submit(() -> {
+		    Thread.sleep(500);
+		    return "thread 1 done";
+		});
+		Future<String> op2 = executor.submit(() -> {
+		    Thread.sleep(500);
+		    return "thread 2 done";
+		});
+		try {
+			System.out.println(op1.get());
+			System.out.println(op2.get());
+		} catch (InterruptedException | ExecutionException e) {
+			e.printStackTrace();
+		}
+		
+	}
+}

Class16/bin/com/david/class165/Example3.class

@@ -0,0 +1,22 @@
+package com.david.class165;
+
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.atomic.AtomicInteger;
+
+public class Example3 {
+	public static void main(String[] args) {
+		AtomicInteger counter = new AtomicInteger();
+
+		ExecutorService executor = Executors.newSingleThreadExecutor();
+		executor.submit(() -> {
+		    counter.set(1);
+		    System.out.println("counter 1 :"+counter.get());
+		});
+		executor.submit(() -> {
+		    counter.compareAndSet(1, 2);
+		    System.out.println("counter 2 : "+counter.get());
+		});
+		
+	}
+}

Class16/bin/module-info.class

@@ -0,0 +1,2 @@
+module Class16 {
+}