线程池小程序(Java)(二)

2014-11-24 07:51:10 · 作者: · 浏览: 3


/**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
//创建等待队列
BlockingQueue bqueue=new ArrayBlockingQueue(20);
//创建一个单个线程数的线程池,他可安排在延迟完成后运行命令或者定期的执行
ThreadPoolExecutor pool=new ThreadPoolExecutor(2, 3, 2, TimeUnit.MILLISECONDS, bqueue);
//创建实现了Runnable接口对象,Thread的对象相应也实现了Runnable接口
Thread t1=new MyThread4();
Thread t2=new MyThread4();
Thread t3=new MyThread4();
Thread t4=new MyThread4();
Thread t5=new MyThread4();
Thread t6=new MyThread4();
Thread t7=new MyThread4();
//将线程放入池中进行执行
pool.execute(t1);
pool.execute(t2);
pool.execute(t3);
pool.execute(t4);
pool.execute(t5);
pool.execute(t6);
pool.execute(t7);
//关闭线程池
pool.shutdown();

}

}
class MyThread4 extends Thread
{
public void run()
{
System.out.println(Thread.currentThread().getName()+"····正在运行");
try
{
Thread.sleep(100l);
}
catch (InterruptedException e)
{
e.printStackTrace();
}
}


}
//本来该看分词器 路线有点错了 回头!!

摘自 Wildcat的专栏