多线程读取文件

1、多线程读取文件 Java多线程文件读取单线程读取10K个 文件的话会显的非常的慢，但是如果我们开启多个线程去读取，会让读取的速度大大的加快，顺便说一下多线程的注意事项：synchronized 代码快中 尽量简短，不要有 类似socket.accept() inputstream.read() 这样的阻塞式的方法，这样会让程序减慢，如果synchronized代码快中的东西太多，容易造成单线程的囧地，而且速度还不如单线程快。废话少说，我们来看看代码：-1.生成10K个 文件：package com.fileThread;import java.io.File;import java.io.Fi

2、leOutputStream;import java.io.OutputStream;public class GenFile     /*     * param args     * throws Exception     */    public static void main(String args) throws Exception       

3、0; File file = null;        OutputStream out = null;        file = new File("c:/file");        if(!file.exists()            file.mkdirs();   

4、;             for (int i = 0; i < 10000; i+)             file = new File("c:/file/file" + i + ".txt");            out = new FileOutputStream(f

5、ile);            out.write("nihao1hh1hh1".getBytes();            out.close();                file = null;      

6、0; 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

7、        Sum sum = new Sum();        Thread t1 = new Thread(sum);        Thread t2 = new Thread(sum);        Thread t3 = new Thread(sum);        t1.sta

8、rt();        t2.start();        t3.start();        / t1.run();        / t2.run();        / t3.run();        / System.out

9、.println(sum.getSum()+"=");    class Sum implements Runnable     private Integer i = 0;    private Integer sum = 0;    static long time;    public void run()         File file = null;&#

10、160;       InputStream is = null;        StringBuffer sb = null;        while (true)             if (i = 0)              

11、;   time = System.currentTimeMillis();                        if (i = 10000)                 break;       

12、60;               synchronized (this)                 file = new File("c:/file/file" + i + ".txt");             

13、60;  / System.out.println(i + "currentThread=" +                / Thread.currentThread().getName();               i+;         

14、;                          try                 is = new FileInputStream(file);            catch (Fil

15、eNotFoundException e)                         byte data = new byte2048;            int len = 0;            sb = new Stri

16、ngBuffer();            try                 while (len = is.read(data) != -1)                     sb.append(new String(da

17、ta, 0, len);                            catch (IOException e)                         String result = sb.

18、toString();            String arr = result.split("D+");            synchronized (this)                 for (String s : arr)   

19、0;                 if (s != null && s.trim().length() > 0)                         sum += Integer.parseInt(s);     

20、0;                                                          file = null;  &

21、#160;     sb = null;        is = null;        System.out.println(this.sum);        System.out.println(System.currentTimeMillis() - time);        public Integer getI(

22、)         return i;        public void setI(Integer i)         this.i = i;        public Integer getSum()         return sum;     

23、   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.IOExceptio

24、n;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

25、 = new Thread(sum);        Thread t3 = new Thread(sum);        t1.start();        t2.start();        t3.start();        / 22562    

26、0;   / 14625    class Sums implements Runnable     private Integer i = 0;    private Integer sum = 0;    static long time;    public void run()         File file = null;  

27、0;     InputStream is = null;        StringBuffer sb = null;        while (true)             if (i = 0)                

28、time = System.currentTimeMillis();                        if (i = 10000)                 break;           

29、;             synchronized (this)                 file = new File("c:/file/file" + i + ".txt");/                Sys

30、tem.out.println(i + "currentThread="/                        + Thread.currentThread().getName();                i+;     

31、           try                     is = new FileInputStream(file);                catch (FileNotFoundException e)   

32、;                              byte data = new byte2048;                int len = 0;         &#

33、160;      sb = new StringBuffer();                try                     while (len = is.read(data) != -1)        

34、                 sb.append(new String(data, 0, len);                                    catch (IOExceptio

35、n e)                                 String result = sb.toString();                String arr = result.split("D+&qu

36、ot;);                for (String s : arr)                     if (s != null && s.trim().length() > 0)           &#

37、160;             sum += Integer.parseInt(s);                                            &#

38、160;                   file = null;        sb = null;        is = null;        System.out.println(this.sum);      &

39、#160; System.out.println(System.currentTimeMillis() - time);        public Integer getI()         return i;        public void setI(Integer i)         this.i = i;   

40、     public Integer getSum()         return sum;        public void setSum(Integer sum)         this.sum = sum;    -单线程去读的速度：package com.fileThread;import java.io.File;import java.

41、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;      

42、0; long time = 0;        int sum =0;        File file = null;        InputStream is = null;        StringBuffer sb = null;        while (true)  &

43、#160;          if (i = 0)                 time = System.currentTimeMillis();                        if (i = 10000)

44、                break;                        file = new File("c:/file/file" + i + ".txt");        &

45、#160;   i+;            try                 is = new FileInputStream(file);            catch (FileNotFoundException e)    

46、60;                   byte data = new byte2048;            int len = 0;            sb = new StringBuffer();            try                 while (len = is.read(data) != -1)         &