java的线程池的使用

1、线程池的创立
1、首先创立一个类，然后完成Runnable接口
publicclassExectorTestimplementsRunnable{}
2、首先声明一个线程池的全局变量
publicclassExectorTestimplementsRunnable{
//线程池
privateExecutorServiceexecutorPool;
}
3、然后在run()办法中，创立线程池实例，创立线程池的时分，切记创立守护线程，这样能够避免你的效劳中止后，效劳的线程还没中止，就是tomcat的进程还在的状况呈现。
复制代码
publicclassExectorTestimplementsRunnable{
//线程池
privateExecutorServiceexecutorPool;
@Override
publicvoidrun(){
//创立线程池，设置为守护进程，能够和主线程一同关闭
this.executorPool=Executors.newFixedThreadPool(this.numThreads,newThreadFactory(){
@Override
publicThreadnewThread(Runnabler){
Threadthread=Executors.defaultThreadFactory().newThread(r);
thread.setDaemon(true);
returnthread;
}
});
}
}
复制代码
4、然后我们需求循环需求处置的办法个数，在循环中调用线程池的办法
复制代码
publicclassExectorTestimplementsRunnable{
//线程池
privateExecutorServiceexecutorPool;
@Override
publicvoidrun(){
//创立线程池，设置为守护进程，能够和主线程一同关闭
this.executorPool=Executors.newFixedThreadPool(this.numThreads,newThreadFactory(){
@Override
publicThreadnewThread(Runnabler){
Threadthread=Executors.defaultThreadFactory().newThread(r);
thread.setDaemon(true);
returnthread;
}
});
//循环处置的办法
ListhandleList=newArrayList();
for(Stringhandler:handleList){
this.executorPool.submit(newHandler());
}
}
}
复制代码
5、将处置的办法贴上
复制代码
publicclassExectorTestimplementsRunnable{
//线程池
privateExecutorServiceexecutorPool;
@Override
publicvoidrun(){
//创立线程池，设置为守护进程，能够和主线程一同关闭
this.executorPool=Executors.newFixedThreadPool(this.numThreads,newThreadFactory(){
@Override
publicThreadnewThread(Runnabler){
Threadthread=Executors.defaultThreadFactory().newThread(r);
thread.setDaemon(true);
returnthread;
}
});
//循环处置的办法
ListhandleList=newArrayList();
for(Stringhandler:handleList){
this.executorPool.submit(newHandler());
}
}
/**
*数据处置线程
*/
publicstaticclassHandlerimplementsRunnable{
publicHandler(){}
@Override
publicvoidrun(){
//处置数据的办法
}
}
}
复制代码
2、线程池的关闭
6、最后补全中止线程池的办法，@PreDestroy办法是在spring销毁之前会调用的办法
复制代码
publicclassExectorTestimplementsRunnable{
//线程池
privateExecutorServiceexecutorPool;
@Override
publicvoidrun(){
//创立线程池，设置为守护进程，能够和主线程一同关闭
this.executorPool=Executors.newFixedThreadPool(this.numThreads,newThreadFactory(){
@Override
publicThreadnewThread(Runnabler){
Threadthread=Executors.defaultThreadFactory().newThread(r);
thread.setDaemon(true);
returnthread;
}
});
//循环处置的办法
ListhandleList=newArrayList();
for(Stringhandler:handleList){
this.executorPool.submit(newHandler());
}
}
/**
*数据处置线程
*/
publicstaticclassHandlerimplementsRunnable{
publicHandler(){}
@Override
publicvoidrun(){
//处置数据的办法
}
}
@PreDestroy
publicvoidshutdown(){
//关闭线程池，会等候线程的执行完成
if(this.executorPool!=null){
//关闭线程池
this.executorPool.shutdown();
//等候关闭完成,等候五秒
try{
if(!this.executorPool.awaitTermination(5,TimeUnit.SECONDS)){
log.info(“Timedoutwaitingforconsumerthreadstoshutdown,exitinguncleanly!!”);
}
}catch(InterruptedExceptione){
log.info(“Interruptedduringshutdown,exitinguncleanly!!”);
}
}
}
}