单线程读取10K个 文件的话会显的非常的慢，但是如果我们开启多个线程去读取，会让读取的速度大大的加快，顺便说一下多线程的注意事项：synchronized 代码快中 尽量简短，不要有 类似socket.accept() inputstream.read() 这样的阻塞式的方法，这样会让程序减慢，如果synchronized代码快中的东西太多，容易造成单线程的囧地，而且速度还不如单线程快。
废话少说，我们来看看代码：
1.生成10K个 文件：
package com.fileThread;
import java.io.File;
import java.io.FileOutputStream;
import java.io.OutputStream;
public class GenFile {
/**
* @param args
* @throws Exception
*/
public static void main(String[] args) throws Exception {
File file = null;
OutputStream out = null;
file = new File("c:/file");
if(!file.exists()){
file.mkdirs();
}
for (int i = 0; i < 10000; i++) {
file = new File("c:/file/file" + i + ".txt");
out = new FileOutputStream(file);
out.write("nihao1hh1hh1".getBytes());
out.close();
}
file = null;
out = null;
}
}
多线程 读取
package com.fileThread;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStream;
public class ReadFile {
public static void main(String[] args) throws Exception {
Sum sum = new Sum();
Thread t1 = new Thread(sum);
Thread t2 = new Thread(sum);
Thread t3 = new Thread(sum);
t1.start();
t2.start();
t3.start();
// t1.run();
// t2.run();
// t3.run();
// System.out.println(sum.getSum()+"==");
}
}
class Sum implements Runnable {
private Integer i = 0;
private Integer sum = 0;
static long time;
public void run() {
File file = null;
InputStream is = null;
StringBuffer sb = null;
while (true) {
if (i == 0) {
time = System.currentTimeMillis();
}
if (i == 10000) {
break;
}
synchronized (this) {
file = new File("c:/file/file" + i + ".txt");
// System.out.println(i + "currentThread==" +
// Thread.currentThread().getName());
i++;
}
try {
is = new FileInputStream(file);
} catch (FileNotFoundException e) {
}
byte[] data = new byte[2048];
int len = 0;
sb = new StringBuffer();
try {
while ((len = is.read(data)) != -1) {
sb.append(new String(data, 0, len));
}
} catch (IOException e) {
}
String result = sb.toString();
String[] arr = result.split("\\D+");
synchronized (this) {
for (String s : arr) {
if (s != null && s.trim().length() > 0) {
sum += Integer.parseInt(s);
}
}
}
}
file = null;
sb = null;
is = null;
System.out.println(this.sum);
System.out.println(System.currentTimeMillis() - time);
}
public Integer getI() {
return i;
}
public void setI(Integer i) {
this.i = i;
}
public Integer getSum() {
return sum;
}
public void setSum(Integer sum) {
this.sum = sum;
}
}
所有的东西 都放到 synchronazied代码快中的速度比较，这个类似单线程
package com.fileThread;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStream;
public class ReadFileAll {
public static void main(String[] args) throws Exception {
Sums sum = new Sums();
Thread t1 = new Thread(sum);
Thread t2 = new Thread(sum);
Thread t3 = new Thread(sum);
t1.start();
t2.start();
t3.start();
// 22562
// 14625
}
}
class Sums implements Runnable {
private Integer i = 0;
private Integer sum = 0;
static long time;
public void run() {
File file = null;
InputStream is = null;
StringBuffer sb = null;
while (true) {
if (i == 0) {
time = System.currentTimeMillis();
}
if (i == 10000) {
break;
}
synchronized (this) {
file = new File("c:/file/file" + i + ".txt");
// System.out.println(i + "currentThread=="
// + Thread.currentThread().getName());
i++;
try {
is = new FileInputStream(file);
} catch (FileNotFoundException e) {
}
byte[] data = new byte[2048];
int len = 0;
sb = new StringBuffer();
try {
while ((len = is.read(data)) != -1) {
sb.append(new String(data, 0, len));
}
} catch (IOException e) {
}
String result = sb.toString();
String[] arr = result.split("\\D+");
for (String s : arr) {
if (s != null && s.trim().length() > 0) {
sum += Integer.parseInt(s);
}
}
}
}
file = null;
sb = null;
is = null;
System.out.println(this.sum);
System.out.println(System.currentTimeMillis() - time);
}
public Integer getI() {
return i;
}
public void setI(Integer i) {
this.i = i;
}
public Integer getSum() {
return sum;
}
public void setSum(Integer sum) {
this.sum = sum;
}
}
单线程去读的速度：
package com.fileThread;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStream;
public class ReadFileSingleThread {
public static void main(String[] args) throws Exception {
int i = 0;
long time = 0;
int sum =0;
File file = null;
InputStream is = null;
StringBuffer sb = null;
while (true) {
if (i == 0) {
time = System.currentTimeMillis();
}
if (i == 10000) {
break;
}
file = new File("c:/file/file" + i + ".txt");
i++;
try {
is = new FileInputStream(file);
} catch (FileNotFoundException e) {
}
byte[] data = new byte[2048];
int len = 0;
sb = new StringBuffer();
try {
while ((len = is.read(data)) != -1) {
sb.append(new String(data, 0, len));
}
} catch (IOException e) {
}
String result = sb.toString();
String[] arr = result.split("\\D+");
for (String s : arr) {
if (s != null && s.trim().length() > 0) {
sum += Integer.parseInt(s);
}
}
}
file = null;
sb = null;
is = null;
System.out.println(sum);
System.out.println(System.currentTimeMillis() - time);
}
}
通过比较，大家就可以发现多线程的好处了，可能大家多如何写多线程存在疑问，这里我想说的是多想想，你的多线程是想做什么，就像 这个 例子，我的多线程 就是想 每个人线程分担 不同的文件读取，再算总和，所以我要控制的同步资源就是文件的名称和总和，所以我就需要把这两个 属性 同步上，这样就可以。如何返回多线程执行完的结果呢，我个人认为这样做，是让其他线程在mian 之前完成，这样就可以达到效果，可以用thread.join()方法，这样在执行mian 之前就会先把多线程执行完，就可以的到结果。
分享到：
相关推荐
Java多线程读大文件 java多线程写文件：多线程往队列中写入数据
Qt Creator 多线程读取文件到程序显示 利用QT Creator多任务读取一个文档到程序里 为了防止直接读取文件里的内容太大而发生卡顿，于是多线程读取将更高效的解决这个问题。 效果图如下： 其中pro文件无需改动，...
简单的利用互斥变量、原子操作等技术实现多线程读写文件时的互斥，从而确保文件在操作过程中不会被破坏。例子并没有使用很多复杂的逻辑。适合刚接触多线程编程的新手学习理解多线程程序的编程思路。
易语言多线程读取大文本文件源码,多线程读取大文本文件,线程读取,WideCharToMultiByte
多线程通信读写文件代码，根据其他的代码文档修改，用于学习多线程通信。
适合的读者：初学用多线程实现对串口的异步操作，对线程的理解，以及对串口的读写。还有文件的读写都有最基本的使用方式。调试时，可以用串口调试助手一起结合的去学习~
多线程对文件读写操作(java)，提高对文件读写效率。
多线程随机读取文件RandomAccessFile
主要为大家详细介绍了python多线程同步之文件读写控制，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
主要介绍了java多线程读写文件示例,需要的朋友可以参考下
vc++读取写入文件 读取写入文件 带进度条的文件读写 多线程读写文件 带进度条可停止的多线程读写文件
使用多线程实现同步读写的一个小程序，同时开启读线程和写线程。当写线程写入一个数字时，读线程读取该数字。
读文件费时间，所以开一个线程读文件。 抽象后的类似demo： 假定读文件需要0.6秒，图像处理（用存文件代替）需要0.5秒，各执行100次。 类和函数 读取文件函数： 一，List增加本序号（0开始）。 二，随机生成5000...
用独立的 TThread 单元 在同一个进程中 将 一份数据很多的文件 分成 两块 同事来读取。 提快速度。
Python的多线程在io方面比单线程还是有优势，但是在多线程开发时，少不了对文件的读写操作。在管理多个线程对同一文件的读写操作时，就少不了文件锁了。 使用fcntl 在linux下，python的标准库有现成的文件锁，来自于...
qt 多线程实现样例，实现文件的拷贝，亲测可用，重新编译即可
NULL 博文链接：https://wpf-0604.iteye.com/blog/2348093
Java多线程读取大文本文件并批量插入MongoDB的代码，文本文件,csv文件，可以结合POI改造使其支持excel。 适合做大量文本数据或日志文件入库的场景，大文本被拆分成多个线程处理，速度快。 批量插入MongoDB，存在则...