import java.io.BufferedInputStream;

import java.io.BufferedOutputStream;

import java.io.FileInputStream;

import java.io.FileNotFoundException;

import java.io.FileOutputStream;

class Job implements Runnable{

private String fileName;

Job(String fileName){

this.fileName = fileName;

}

@Override

public void run() {

System.out.println("Thread Start "+Thread.currentThread());

long startTime = System.currentTimeMillis();

try {

FileOutputStream fo

=new FileOutputStream("C:\\MyData\\"+fileName);

BufferedOutputStream bo =

new BufferedOutputStream(fo,12000);

FileInputStream fi

= new FileInputStream("C:\\MyData\\Test.dat");

BufferedInputStream bi =

new BufferedInputStream(fi,12000);

int singleChar = bi.read();

while(singleChar!=-1){

bo.write(singleChar);

singleChar = bi.read();

}

fo.close();

fi.close();

//bi.close();

//bo.close();

long endTime = System.currentTimeMillis();

System.out.println("File Done... "+Thread.currentThread());

System.out.println("Time Taken "+(endTime-startTime));

} catch (Exception e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

/*for(int i = 1; i<=5 ; i++){

System.out.println(" I is "+i

+" Thread "+Thread.currentThread());

}*/

}

}

public class Demo1 {

public static void main(String[] args) {

Job job1 = new Job("test2.dat");

Job job2 = new Job("test3.dat");

Thread worker1 = new Thread(job1,"ram");

Thread worker2 = new Thread(job2,"shyam");

worker1.start();

worker2.start();

//System.out.println(Thread.currentThread());

}

}