Java线程：新特征-线程池

核心提示： pool-1-thread-1正在执行，，Java线程：新特征-线程池(4)，，pool-1-thread-2正在执行，Thread对象当然也实现了Runnable接口Threadt1=newMyThread();Threadt2=newMyThread();Threadt3=newMyThre

pool-1-thread-1正在执行。。。
pool-1-thread-2正在执行。。。
pool-1-thread-1正在执行。。。
pool-1-thread-1正在执行。。。
pool-1-thread-2正在执行。。。
Process　finished　with　exit　code　0

五、单任务延迟连接池

在四代码基础上，做改动

　　　　　　　　　　　　　　　　//创建一个单线程执行程序，它可安排在给定延迟后运行命令或者定期地执行。
　　　　　　　　　　　　　　　　ScheduledExecutorService　pool　=　Executors.newSingleThreadScheduledExecutor();

pool-1-thread-1正在执行。。。
pool-1-thread-1正在执行。。。
pool-1-thread-1正在执行。。。
pool-1-thread-1正在执行。。。
pool-1-thread-1正在执行。。。
Process　finished　with　exit　code　0

六、自定义线程池

import　java.util.concurrent.ArrayBlockingQueue;
import　java.util.concurrent.BlockingQueue;
import　java.util.concurrent.ThreadPoolExecutor;
import　java.util.concurrent.TimeUnit;
/**
*　Java线程：线程池-自定义线程池
*
*　@author　Administrator　
*/
public　class　Test　{
　　　　　　　　public　static　void　main(String[]　args)　{
　　　　　　　　　　　　　　　　//创建等待队列
　　　　　　　　　　　　　　　　BlockingQueue<Runnable>　bqueue　=　new　ArrayBlockingQueue<Runnable>(20);
　　　　　　　　　　　　　　　　//创建一个单线程执行程序，它可安排在给定延迟后运行命令或者定期地执行。
　　　　　　　　　　　　　　　　ThreadPoolExecutor　pool　=　new　ThreadPoolExecutor(2,3,2,TimeUnit.MILLISECONDS,bqueue);
　　　　　　　　　　　　　　　　//创建实现了Runnable接口对象，Thread对象当然也实现了Runnable接口
　　　　　　　　　　　　　　　　Thread　t1　=　new　MyThread();
　　　　　　　　　　　　　　　　Thread　t2　=　new　MyThread();
　　　　　　　　　　　　　　　　Thread　t3　=　new　MyThread();
　　　　　　　　　　　　　　　　Thread　t4　=　new　MyThread();
　　　　　　　　　　　　　　　　Thread　t5　=　new　MyThread();
　　　　　　　　　　　　　　　　Thread　t6　=　new　MyThread();
　　　　　　　　　　　　　　　　Thread　t7　=　new　MyThread();
　　　　　　　　　　　　　　　　//将线程放入池中进行执行
　　　　　　　　　　　　　　　　pool.execute(t1);
　　　　　　　　　　　　　　　　pool.execute(t2);
　　　　　　　　　　　　　　　　pool.execute(t3);
　　　　　　　　　　　　　　　　pool.execute(t4);
　　　　　　　　　　　　　　　　pool.execute(t5);
　　　　　　　　　　　　　　　　pool.execute(t6);
　　　　　　　　　　　　　　　　pool.execute(t7);
　　　　　　　　　　　　　　　　//关闭线程池
　　　　　　　　　　　　　　　　pool.shutdown();
　　　　　　　　}
}
class　MyThread　extends　Thread　{
　　　　　　　　@Override
　　　　　　　　public　void　run()　{
　　　　　　　　　　　　　　　　System.out.println(Thread.currentThread().getName()　+　"正在执行。。。");
　　　　　　　　　　　　　　　　try　{
　　　　　　　　　　　　　　　　　　　　　　　　Thread.sleep(100L);
　　　　　　　　　　　　　　　　}　catch　(InterruptedException　e)　{
　　　　　　　　　　　　　　　　　　　　　　　　e.printStackTrace();
　　　　　　　　　　　　　　　　}
　　　　　　　　}
}