How To Read A File Using Multithreading In Java

It says multiple tasks tin be done at a time but really its non exactly like that.
It will continue the cpu idle time less. Because cpu will take a responsibility to execute many threads if nosotros
Use multithreading.
If its single threaded application and then it might go along the cpu idle for some fourth dimension and hence lowers the performance.

Lets meet the same through example.

Requirement
Read multiple files from a location and write the content of each file to the same destination file by appending each time.

i accept kept total 3000 files in the source location to read and i will create one thread to read and write 1 file content in multithreading scenario whereas in single thread scenario for loop iterates 3000 times to read and write 3000 files.

Lets use single threaded program

1. packet com.kb ;

3. import coffee.io.BufferedReader ;

4. import coffee.io.BufferedWriter ;

5. import java.io.File ;

6. import java.io.FileNotFoundException ;

7. import coffee.io.FileReader ;

8. import java.io.FileWriter ;

9. import java.io.IOException ;

11. public class SingleThreadWriteToFile {

13. public static void main( Cord [ ] args) {

14. long startTime = System.nanoTime ( ) ;

17. File dir = new File ( "E:\\java\\sample files" ) ;

18. File destination = new File ( "East:\\coffee\\sample files\\Destination.txt" ) ;

19. File [ ] files = dir.listFiles ( ) ;

20. String content;

21. for ( File file : files) {

22.         content = readFromFile(file.getAbsolutePath ( ) ) ;

23.         writeToFile(destination,content) ;

24. }

25. long stopTime = System.nanoTime ( ) ;

27. System.out.println ( "Full execution time is " + (stopTime - startTime) ) ;

28. }

30. private static void writeToFile( File file,String content) {

31. try {

32. BufferedWriter writer = new BufferedWriter ( new FileWriter (file,true ) ) ;

33.             writer.write (content) ;

34.             writer.affluent ( ) ;

35. } catch ( IOException e) {

36. // TODO Auto-generated take hold of cake

37.             east.printStackTrace ( ) ;

38. }

41. }

43. static String readFromFile( String filename) {

44. StringBuffer content = new StringBuffer ( ) ;

45. try {

46. String text;

47. BufferedReader reader = new BufferedReader ( new FileReader (filename) ) ;

48. while ( (text = reader.readLine ( ) ) != nada ) {

49.                     content.append (text) ;

50.                     content.append ( "\north" ) ;

52. }

54. } catch ( FileNotFoundException east) {

55. // TODO Auto-generated take hold of cake

56.             e.printStackTrace ( ) ;

57. }

58. catch ( IOException e) {

59. // TODO Auto-generated catch block

60.             due east.printStackTrace ( ) ;

61. }

62. render content.toString ( ) ;

63. }

65. }

package com.kb;  import java.io.BufferedReader; import java.io.BufferedWriter; import java.io.File; import java.io.FileNotFoundException; import java.io.FileReader; import java.io.FileWriter; import java.io.IOException;  public grade SingleThreadWriteToFile {  	public static void main(String[] args) { 		long startTime = System.nanoTime(); 		 		 		File dir = new File("E:\\java\\sample files"); 		File destination = new File("East:\\java\\sample files\\Destination.txt"); 		File[] files = dir.listFiles(); 		String content; 		for (File file : files) { 		content = readFromFile(file.getAbsolutePath()); 		writeToFile(destination,content); 		} 		long stopTime = System.nanoTime(); 		 System.out.println("Total execution time is "+(stopTime - startTime));		 	} 	 	private static void writeToFile(File file,String content) { 		try { 			BufferedWriter writer = new BufferedWriter(new FileWriter(file,true)); 			writer.write(content); 			author.flush(); 		} catch (IOException due east) { 			// TODO Car-generated catch cake 			due east.printStackTrace(); 		} 		 		 	}  	static String readFromFile(String filename){ 		StringBuffer content = new StringBuffer(); 		endeavor { 			String text; 			BufferedReader reader = new BufferedReader(new FileReader(filename)); 				while((text = reader.readLine())!=null){ 					content.append(text); 					content.append("\north"); 					 				} 			  		} grab (FileNotFoundException e) { 			// TODO Auto-generated catch cake 			e.printStackTrace(); 		} 		catch (IOException eastward) { 			// TODO Auto-generated take hold of block 			e.printStackTrace(); 		} 	return content.toString();	 	}  }

Output is

2197765530

Now lets utilize multithreading to the above program.

Here how information technology goes

1. package com.kb ;

3. import java.io.BufferedReader ;

4. import java.io.BufferedWriter ;

5. import java.io.File ;

6. import java.io.FileNotFoundException ;

7. import java.io.FileReader ;

8. import coffee.io.FileWriter ;

9. import java.io.IOException ;

11. public class MultithreadingWriteToFile {

13. public static void main( String [ ] args) {

14. Thread.currentThread ( ).setPriority ( Thread.MIN_PRIORITY ) ;

15. long startTime = System.nanoTime ( ) ;

16. File dir = new File ( "E:\\java\\sample files" ) ;

17. File destination = new File ( "E:\\java\\sample files\\DestinationMultiThread.txt" ) ;

18. File [ ] files = dir.listFiles ( ) ;

19. for ( File file : files) {

20. Author w1 = new Writer (file, destination) ;

21. Thread t = new Thread (w1) ;

22.             t.setPriority ( Thread.MAX_PRIORITY ) ;

23.             t.commencement ( ) ;

25. }

26. long stopTime = Organization.nanoTime ( ) ;

29. System.out.println ( "Total execution time is " + (stopTime - startTime) ) ;

31. }

33. }

35. class Author implements Runnable {

36. File source;

37. File destination;

38. public Author ( File source,File destination) {

39. this.source = source;

40. this.destination = destination;

41. }

42.     @Override

43. public void run( ) {

44. String content;

45.         content = readFromFile(source.getAbsolutePath ( ) ) ;

46.         writeToFile(destination,content) ;

47. }

49. private static void writeToFile( File file,String content) {

50. endeavour {

51. BufferedWriter author = new BufferedWriter ( new FileWriter (file,true ) ) ;

52.             author.write (content) ;

53.             writer.write ( "file content written" ) ;

54.             writer.flush ( ) ;

55. } grab ( IOException eastward) {

56. // TODO Auto-generated take hold of block

57.             e.printStackTrace ( ) ;

58. }

61. }

63. static Cord readFromFile( String filename) {

64. StringBuffer content = new StringBuffer ( ) ;

65. attempt {

66. String text;

67. BufferedReader reader = new BufferedReader ( new FileReader (filename) ) ;

68. while ( (text = reader.readLine ( ) ) != null ) {

69.                     content.suspend (text) ;

70.                     content.append ( "\due north" ) ;

72. }

74. } take hold of ( FileNotFoundException eastward) {

75. // TODO Car-generated grab block

76.             eastward.printStackTrace ( ) ;

77. }

78. catch ( IOException e) {

79. // TODO Auto-generated catch block

80.             eastward.printStackTrace ( ) ;

81. }

82. return content.toString ( ) ;

83. }

86. }

parcel com.kb;  import java.io.BufferedReader; import java.io.BufferedWriter; import java.io.File; import java.io.FileNotFoundException; import java.io.FileReader; import java.io.FileWriter; import coffee.io.IOException;  public class MultithreadingWriteToFile { 	 	public static void main(Cord[] args) { 		Thread.currentThread().setPriority(Thread.MIN_PRIORITY); 		long startTime = System.nanoTime(); 		File dir = new File("Due east:\\coffee\\sample files"); 		File destination = new File("E:\\java\\sample files\\DestinationMultiThread.txt"); 		File[] files = dir.listFiles(); 		for (File file : files) { 			Author w1 = new Writer(file, destination); 			Thread t = new Thread(w1); 			t.setPriority(Thread.MAX_PRIORITY); 			t.start(); 			 		} 		long stopTime = Organisation.nanoTime(); 		 	 System.out.println("Total execution time is "+(stopTime - startTime)); 		 	}  }  class Writer implements Runnable{ File source; File destination; 	public Writer(File source,File destination) { this.source = source; this.destination = destination; 	} 	@Override 	public void run() { 		Cord content; 		content = 	readFromFile(source.getAbsolutePath()); 		writeToFile(destination,content);		 	} 	 	private static void writeToFile(File file,String content) { 		try { 			BufferedWriter author = new BufferedWriter(new FileWriter(file,true)); 			writer.write(content); 			writer.write("file content written"); 			author.affluent(); 		} catch (IOException e) { 			// TODO Automobile-generated catch block 			east.printStackTrace(); 		} 		 		 	}  	static String readFromFile(String filename){ 		StringBuffer content = new StringBuffer(); 		endeavor { 			String text; 			BufferedReader reader = new BufferedReader(new FileReader(filename)); 				while((text = reader.readLine())!=goose egg){ 					content.append(text); 					content.append("\n"); 					 				} 			  		} catch (FileNotFoundException e) { 			// TODO Auto-generated catch block 			e.printStackTrace(); 		} 		catch (IOException eastward) { 			// TODO Auto-generated take hold of block 			e.printStackTrace(); 		} 	return content.toString();	 	}  	 }

Output is

1801077879

See the time difference between each output is
396687651 nano seconds.

This is how multithreading helps us to attain the functioning.

About the Author

Founder of javainsimpleway.com
I love Coffee and open up source technologies and very much passionate about software development.
I like to share my cognition with others especially on technology 🙂
I accept given all the examples equally simple as possible to empathise for the beginners.
All the code posted on my blog is developed,compiled and tested in my development environment.
If you find whatsoever mistakes or bugs, Delight drib an electronic mail to kb.knowledge.sharing@gmail.com

Connect with me on Facebook for more than updates

How To Read A File Using Multithreading In Java,

Source: http://javainsimpleway.com/multithreading-in-java/

Posted by: walkerdeboyfaing.blogspot.com

Share this post