梦幻之旅

DEBUG - 天道酬勤
   :: 首页 :: 新随笔 :: 联系 :: 聚合  :: 管理 ::
  671 随笔 :: 6 文章 :: 256 评论 :: 0 Trackbacks
java 线程池
1.实现Runnable接口
package hasreturn;

public class MyThread implements Runnable
{   
    private String name;
    
    public MyThread(String name)
    {
        this.name = name;
    }
    
    public void run()
    {
        try
        {
            Thread.sleep(1000*3);
        }
        catch(Exception ex)
        {}
        System.out.println(this.name + "正在执行..");
    }
}
2. 线程池
package hasreturn;

import java.util.concurrent.Executors;

import java.util.concurrent.ExecutorService;

public class ThreadPool
{
    
    public static void main(String[] args)
    {
        // 创建一个可重用固定线程数的线程池
        ExecutorService pool = Executors.newFixedThreadPool(1);
        
        // 创建实现了Runnable接口对象，Thread对象当然也实现了Runnable接口
        
        MyThread t1 = new MyThread("A");
        MyThread t2 = new MyThread("B");
        MyThread t3 = new MyThread("C");
        MyThread t4 = new MyThread("D");
        MyThread t5 = new MyThread("E");
        
        // 将线程放入池中进行执行
        pool.execute(t1);
        pool.execute(t2);
        pool.execute(t3);
        pool.execute(t4);
        pool.execute(t5);
        
        // 关闭线程池
        pool.shutdown();
        
    }
}

posted on 2011-08-16 21:35 HUIKK 阅读(311) 评论(0)  编辑  收藏 所属分类: Java

只有注册用户登录后才能发表评论。
网站导航: