java多线程同时读取一个文件
2011-06-02 23:08
711 查看
转自:http://zhidao.baidu.com/question/164435216.html?fr=qrl&cid=870&index=5
import java.io.*; class DownThread extends Thread { //定义字节数组(取水的竹筒)的长度 private final int BUFF_LEN = 32; //定义读取的起始点 private long start; //定义读取的结束点 private long end; //读取文件对应的输入流 private InputStream is; //将读取到的字节输出到raf中 private RandomAccessFile raf; //构造器,传入输入流,输出流和读取起始点、结束点 public DownThread(long start, long end, InputStream is, RandomAccessFile raf) { //输出该线程负责读取的字节位置 System.out.println(start + "---->" + end); this.start = start; this.end = end; this.is = is; this.raf = raf; } public void run() { try { is.skip(start); raf.seek(start); //定义读取输入流内容的的缓存数组(竹筒) byte[] buff = new byte[BUFF_LEN]; //本线程负责读取文件的大小 long contentLen = end - start; //定义最多需要读取几次就可以完成本线程的读取 long times = contentLen / BUFF_LEN + 4; //实际读取的字节数 int hasRead = 0; for (int i = 0; i < times; i++) { hasRead = is.read(buff); //如果读取的字节数小于0,则退出循环! if (hasRead < 0) { break; } raf.write(buff, 0, hasRead); } } catch (Exception ex) { ex.printStackTrace(); } //使用finally块来关闭当前线程的输入流、输出流 finally { try { if (is != null) { is.close(); } if (raf != null) { raf.close(); } } catch (Exception ex) { ex.printStackTrace(); } } } } public class MutilDown { public static void main(String[] args) { final int DOWN_THREAD_NUM = 4; final String OUT_FILE_NAME = "d:/copy勇敢的心.rmvb"; InputStream[] isArr = new InputStream[DOWN_THREAD_NUM]; RandomAccessFile[] outArr = new RandomAccessFile[DOWN_THREAD_NUM]; try { isArr[0] = new FileInputStream("d:/勇敢的心.rmvb"); long fileLen = getFileLength(new File("d:/勇敢的心.rmvb")); System.out.println("文件的大小" + fileLen); //以输出文件名创建第一个RandomAccessFile输出流 outArr[0] = new RandomAccessFile(OUT_FILE_NAME, "rw"); //创建一个与文件相同大小的空文件 for (int i = 0; i < fileLen; i++) { outArr[0].write(0); } //每线程应该读取的字节数 long numPerThred = fileLen / DOWN_THREAD_NUM; //整个文件整除后剩下的余数 long left = fileLen % DOWN_THREAD_NUM; for (int i = 0; i < DOWN_THREAD_NUM; i++) { //为每个线程打开一个输入流、一个RandomAccessFile对象, //让每个线程分别负责读取文件的不同部分。 if (i != 0) { isArr[i] = new FileInputStream("d:/勇敢的心.rmvb"); //以指定输出文件创建多个RandomAccessFile对象 outArr[i] = new RandomAccessFile(OUT_FILE_NAME, "rw"); } if (i == DOWN_THREAD_NUM - 1) { //最后一个线程读取指定numPerThred+left个字节 new DownThread(i * numPerThred, (i + 1) * numPerThred + left, isArr[i], outArr[i]).start(); } else { //每个线程负责读取一定的numPerThred个字节 new DownThread(i * numPerThred, (i + 1) * numPerThred, isArr[i], outArr[i]).start(); } } } catch (Exception ex) { ex.printStackTrace(); } } public static long getFileLength(File file) { long length = 0; //获取文件的长度 long size = file.length(); length = size; return length; } }
相关文章推荐
- java多线程读取一个文件
- JAVA多线程读取同一个文件,加速对文件内容的获取
- JAVA多线程读取同一个文件,加速对文件内容的获取
- java中多线程读取同一个文件的不同位置,多线程读取文件
- JAVA多线程之两个线程同时写一个文件
- Java 多线程读取一个文件
- java读取输入流并保存成一个文件
- Java定义一个用来保存全局字符串的properties文件并用ResourceBundle读取它
- JAVA使用多线程读取超大文件
- 在Java中使用多线程结合断点续传实现一个简单的文件下载器
- java读取txt文件,并统计每行中每个字母出现的次数,并将产生的数字保存到一个新的txt文件中(有加分)
- java中怎样用IO流把一个文件全部读取出来
- java多线程读取多个文件 导入数据库
- java使用FileReader读取一个.java文件,并打印在控制台上。
- java代码读取excel文件,同时兼容2003和2007
- 1 多线程下载一个文件(普通的java工程:java实现)
- 分享下java 读取目录及子目录下指定文件名的路径 并放到一个List数组里面返回遍历和写到文件里
- 如何使用JavaExcel(jxl)读取一个文件并写入一个新文件
- java的JFileChooser上传一个Excel文件并读取该文件的内容
- 一个asp文件如何同时读取两个数据…