First Commit

Author: iamtech

ThreadPractice/.classpath

@@ -0,0 +1,6 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<classpath>
+	<classpathentry kind="src" path="src"/>
+	<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER"/>
+	<classpathentry kind="output" path="bin"/>
+</classpath>

ThreadPractice/.gitignore

@@ -0,0 +1 @@
+/bin/

ThreadPractice/.project

@@ -0,0 +1,17 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<projectDescription>
+	<name>ThreadPractice</name>
+	<comment></comment>
+	<projects>
+	</projects>
+	<buildSpec>
+		<buildCommand>
+			<name>org.eclipse.jdt.core.javabuilder</name>
+			<arguments>
+			</arguments>
+		</buildCommand>
+	</buildSpec>
+	<natures>
+		<nature>org.eclipse.jdt.core.javanature</nature>
+	</natures>
+</projectDescription>

ThreadPractice/a.txt

@@ -0,0 +1,67 @@
+package com.example.main;
+
+import java.io.FileInputStream;
+import java.io.FileNotFoundException;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.OutputStream;
+import java.util.concurrent.Executor;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+
+import com.example.util.IOUtil;
+
+
+ class WriteData implements Runnable {
+	String iFile;
+	String oFile;
+	
+	
+	public WriteData(String iFile, String oFile) {
+		this.iFile = iFile;
+		this.oFile = oFile;
+	}
+
+
+	@Override
+	public void run() {
+		try {
+			FileInputStream istream = new FileInputStream(iFile);
+			FileOutputStream ostream =  new FileOutputStream(oFile);
+			System.out.println("Copying File :"+iFile);
+			IOUtil.copyData(istream, ostream);
+		} catch (IOException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}
+	}
+	
+}
+
+public class Application {
+	
+	
+	public static void main(String[] args) throws IOException {
+		
+		String iFile = "a.txt";
+		String oFile = "b.txt";
+		String iFilex = "x.txt";
+		String oFiley = "y.txt";
+		
+	/*	Thread t1 = new Thread(new WriteData(iFile, oFile));
+		t1.start();
+		Thread t2 = new Thread(new WriteData(iFilex, oFiley));
+		t2.start();*/
+		
+		// Use executor to define thread count
+		
+		ExecutorService executor = Executors.newFixedThreadPool(3);  // Thread Pool Size
+		executor.execute(new WriteData(iFile, oFile));
+		executor.execute(new WriteData(iFilex, oFiley));
+		System.out.println("DONE");
+		
+		
+	}
+
+}

ThreadPractice/b.txt

@@ -0,0 +1,67 @@
+package com.example.main;
+
+class IncValue{
+	 int x;
+	 
+	 
+	public IncValue(int x) {
+		this.x = x;
+	}
+
+	public int getX() {
+		return x;
+	}
+
+	public void setX(int x) {
+		this.x = x;
+	}
+	 
+	 public void incVal(){            // public synchronized void incVal(){ 
+		 int y = getX();
+		 y++;
+		 // to pause a thread to that other thread can run
+		 try {
+				Thread.sleep(1);
+			} catch (InterruptedException e) {
+				// TODO Auto-generated catch block
+				e.printStackTrace();
+			}
+		 setX(y);
+		
+	 }
+}
+
+class MyThread extends Thread{
+	IncValue inv;
+	
+	public MyThread(IncValue inv) {
+		this.inv = inv;
+	}
+
+	@Override
+	public void run() {
+		inv.incVal();
+	}
+}
+
+public class SyncTest {
+
+	public static void main(String[] args) {
+		IncValue inv = new IncValue(10);
+		MyThread t1 = new MyThread(inv);
+		MyThread t2 = new MyThread(inv);
+		t1.start();
+		t2.start();
+		
+		try {
+			t1.join();
+			t2.join();
+			Thread.sleep(1000);
+		} catch (InterruptedException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}
+		 System.out.println("value of x is:"+inv.getX()); // should be 12 but will come 11.
+	}
+
+}

ThreadPractice/src/com/example/main/Application.java

@@ -0,0 +1,17 @@
+package com.example.util;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.OutputStream;
+
+public class IOUtil {
+	
+	public static void copyData(InputStream istream, OutputStream ostream) throws IOException{
+		
+		int value;
+		while((value = istream.read()) > -1){
+			ostream.write(value);
+		}
+	}
+
+}