java多线程示例

刘宗才

浏览: 34191 次
性别:
来自: 北京

最近访客更多访客>>

leimingchao

a1733687480

cnyoky

QINHONG

博主相关

博客

微博

相册

留言

关于我

文章分类

社区版块

存档分类

博客分类：

java

java 多线程

<div class="iteye-blog-content-contain" style="font-size: 14px"></div>

Java 多线程实例-测试多线程效率

部分代码来自网络
欢迎加入Q-Q群:123866420,加入请说明:来自iteye.com
代码在附件中，方便阅读请下载写最好的文章留个赞哦

创建一个固定大小的txt文件

代码如下:
package test.multiThread;

import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.OutputStream;

publicclass FileCreate {
    privatefinalstatic String path = "C:\\Users\\Administrator\\Desktop\\test1.txt";
    privatefinalstatic String crlf=System.getProperty("line.separator");
    //单位是kb
    privatefinalstaticintsize = 1024*5; //5兆
    //是否限制文件大小
    privatestaticbooleanpsize = true;
    publicstaticvoid main(String[] args) throws IOException {
       File file = null;
        OutputStream out = null;
        if(psize){
        file = new File(path);
        int i=0;
        while(psize && file.length()<= size*1024){
             out = new FileOutputStream(file,true);
             out = new FileOutputStream(file,true);
              out.write((String.valueOf(i)+"------").getBytes());
                out.write(crlf.getBytes());
                i++;
        }
        }else{
        file = new File(path);
        for (int i = 0; i <= 1500; i++) {
              out = new FileOutputStream(file,true);
              out.write((String.valueOf(i)+"------").getBytes());
                out.write(crlf.getBytes());
            }
        }
        if(null != out){
         out.flush();
             out.close();
        }
        file = null;
        out = null;

    }
}

读取文件方法体，继承Runnable实现多线程

代码如下:
package test.multiThread;

import java.io.BufferedReader;
import java.io.FileNotFoundException;
import java.io.FileReader;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;

class MultiThread implements Runnable{
    private static BufferedReader br = null;
    private List<String> list;

    static{
        try {
            br = new BufferedReader(new FileReader("C:\\Users\\Administrator\\Desktop\\test1.txt"),3);
        } catch (FileNotFoundException e) {
            e.printStackTrace();
        }
    }

    public void run() {
        String line = null;
        int count = 0;
        while(true) {
            this.list = new ArrayList<String>();
            synchronized(br) {
                try {
                    while((line = br.readLine()) != null) {
                        if(count<3) {
                            list.add(line+Thread.currentThread().getName());
                            count++;
                        }else {
                                 list.add(line+Thread.currentThread().getName());
                            count = 0;
                            break;
                        }
                    }
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            try {
                Thread.sleep(1);
                display(this.list);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            if(line == null)
                break;
        }


    }
    /**
     * 打印读取的内容，不建议打印，影响效率
     */
    public void display(List<String> list) {
        for(String str:list) {
            System.out.println(str);
        }
        //System.out.println(list.size());
    }

}

测试多线程效率
代码如下:
package test.multiThread;

import java.util.Date;

/** @author zongcai_liu
* @email   892530175@qq.com
* 2014-3-12 下午3:36:38
*/
publicclass ThreadReadDemo {
    publicstaticvoid main(String[] args) throws InterruptedException {
       Date now = new Date();
       //线程数目
       int threadNum = 10;
       Thread[] thread = new Thread[threadNum];
       for(int i=0;i<thread.length;i++){
           thread[i] = new Thread(new MultiThread(),String.valueOf(i));
           thread[i].start();
           //thread[i].join();
       }
       for(int i=0;i<thread.length;i++){
           while(thread[i].isAlive()){
            }
       }
        Date end = new Date();
       System.out.println("------线程时间---------");
        System.out.println((end.getTime()-now.getTime())/1000+"秒");
    }
}

测试结果:

5M的txt文件

结果1：开启1个线程读取时间:
第一次:

第2次:


结果2：开启5个线程读取时间:
第一次:

第2次:


结果3：开启10个线程读取时间:
第一次:

第2次:


结果3：开启50个线程读取时间:
第一次:

第2次:

java多线程实例.zip (32.5 KB)
下载次数: 5

分享到：

gwt初学者

2014-03-12 22:48
浏览 875
评论(0)
分类:编程语言
查看更多

发表评论

您还没有登录,请您登录后再发表评论

最近访客更多访客>>

博主相关

文章分类

社区版块

存档分类

最新评论