梦幻之旅

DEBUG - 天道酬勤

   :: 首页 :: 新随笔 :: 联系 :: 聚合  :: 管理 ::
  671 随笔 :: 6 文章 :: 256 评论 :: 0 Trackbacks
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 阅读(315) 评论(0)  编辑  收藏 所属分类: Java

只有注册用户登录后才能发表评论。


网站导航: