Java详解使用线程池处理任务方法

第Java详解使用线程池处理任务方法不使用线程池的问题：

如果用户每发起一个请求，后台就创建一个新线程来处理，下次新任务来了又要创建新线程，而创建新线程的开销是很大的，这样会严重影响系统的性能。

线程池常见面试题：

1、临时线程什么时候创建？

新任务提交时发现核心线程都在忙，任务队列也满了，并且还可以创建临时线程，此时才会创建临时线程。

2、什么时候会开始拒绝任务？

核心线程和临时线程都在忙，任务队列也满了，新的任务过来的时候才会开始任务拒绝。

1、线程池处理Runnable任务

importjava.util.concurrent.*;

publicclass多线程_5线程池处理Runnable任务{

publicstaticvoidmain(String[]args){

//线程池处理Runnable任务

//创建线程池对象

publicThreadPoolExecutor(intcorePoolSize,//核心线程数量

intmaximumPoolSize,//线程池可支持的最大线程数量

longkeepAliveTime,//临时线程的最大存活时间

TimeUnitunit,//指定存活时间的单位（秒，分等）

BlockingQueueRunnableworkQueue,//指定任务队列

ThreadFactorythreadFactory,//指定用哪个线程工厂创建线程

RejectedExecutionHandlerhandler)//指定线程忙，任务满了的时候，新任务来了怎么办

ExecutorServicepool=newThreadPoolExecutor(3,5,

6,TimeUnit.SECONDS,newArrayBlockingQueue(5),

Executors.defaultThreadFactory(),newThreadPoolExecutor.AbortPolicy());

//给任务线程池处理

Runnabler=newMyExe();

//三个核心线程

pool.execute(r);

pool.execute(r);

pool.execute(r);

//五个任务队列（不创建临时线程时，会发现只有三个线程，即核心线程量）

pool.execute(r);

pool.execute(r);

pool.execute(r);

pool.execute(r);

pool.execute(r);

//创建临时线程(五个线程，即最大线程量)

pool.execute(r);

pool.execute(r);

//不创建，拒绝策略被触发

//pool.execute(r);

//关闭线程池（开发中一般不会使用）

//pool.shutdownNow();//立即关闭，即使任务没有执行完毕。会丢失任务的！

//pool.shutdown();//会等待任务全部执行完毕后再关闭（建议使用）

classMyExeimplementsRunnable{

publicvoidrun(){

for(inti=1;ii++){

System.out.println(Thread.currentThread().getName()+"正在执行："+i+"次");

//因为当前案例任务太简单，我们需要创建临时队列需要让三个核心线程忙，五个任务队列排满,所以让线程休眠以增加任务时间

try{

System.out.println(Thread.currentThread().getName()+"任务与线程绑定，线程进入了休眠");

Thread.sleep(1000000);

}catch(Exceptione){

e.printStackTrace();

}

2、线程池处理Callable任务

importjava.util.concurrent.*;

publicclass多线程_5线程池处理Callable任务{

publicstaticvoidmain(String[]args)throwsException{

//线程池处理Callable任务

//创建线程池对象

publicThreadPoolExecutor(intcorePoolSize,//核心线程数量

intmaximumPoolSize,//线程池可支持的最大线程数量

longkeepAliveTime,//临时线程的最大存活时间

TimeUnitunit,//指定存活时间的单位（秒，分等）

BlockingQueueRunnableworkQueue,//指定任务队列

ThreadFactorythreadFactory,//指定用哪个线程工厂创建线程

RejectedExecutionHandlerhandler)//指定线程忙，任务满了的时候，新任务来了怎么办

ExecutorServicepool=newThreadPoolExecutor(3,5,

6,TimeUnit.SECONDS,newArrayBlockingQueue(5),

Executors.defaultThreadFactory(),newThreadPoolExecutor.AbortPolicy());

//给任务线程池处理

//Callablec=newMyCallable2(100);

//pool.submit(c);

FutureStringf1=pool.submit(newMyCallable2(100));

FutureStringf2=pool.submit(newMyCallable2(200));

FutureStringf3=pool.submit(newMyCallable2(300));

FutureStringf4=pool.submit(newMyCallable2(400));

FutureStringf5=pool.submit(newMyCallable2(500));

//Stringstr=f1.get();

//System.out.println(str);

System.out.println(f1.get());

System.out.println(f2.get());

System.out.println(f3.get());

System.out.println(f4.get());

System.out.println(f5.get());

classMyCallable2implementsCallableString{

//v(泛型)

privateintn;

publicMyCallable2(intn){

this.n=n;

//重写call方法

//案例：加法

pub