对于线程池用的也不少,但是最近还是糟了一坑。还是要深入了解一下线程池的使用,以免以后遭重
对于JavaEE项目来说,服务端项目是一直启动着,有的时候需要异步或者大并发的项目来的时候,就会想到使用多线程或者线程池来维护有关的线程。
最近有一个很简单的需求,就是一个方法,可能是异步或者同步返回一个结果。该方法,全局一个调用就够了,不用很多线程同时工作。就想着用future,如果是同步的话就用get获取结果,同步返回。如果是异步的话,就不get,直接异步返回一个正在处理
这个思路是没问题的,于是代码如下(因为原因是一样的问题,所以一下文章不考虑同步情况,只考虑异步)
package threadPools.zxy.threadPools.zxy; import java.util.concurrent.Callable; import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; public class ThreadFuture { private static ThreadPoolExecutor executor = new ThreadPoolExecutor(1, 1, 0, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>()); public static void main(String[] args) { executor.submit(new Callable<String>() { public String call() throws Exception { System.out.println("task-->threadName:" + Thread.currentThread().getName()); Thread.sleep(1000); return null; } }); executor.shutdown(); } }
假设这就是服务器上的代码,其实就是很简单,我计划申请一个线程池,corePoolSize为1, maximumPoolSize为1, keepAliveTime 为0, unit 为秒,workQueue为LinkedBlockingQueue。(其实这个和ExecutorService executor2 = Executors.newSingleThreadExecutor(),基本是一样的,newSingleThreadExecutor()就是封装后的ThreadPoolExecutor,这次就以ThreadPoolExecutor为例)
我的想法很简单,就是就一个线程执行,也不需要其余线程存活时间,异步执行完一遍以后,线程池shutdown,释放线程池,节省空间,等待下一次用户的访问。
结果在服务器上运行该代码,只有第一次访问的时候线程正常执行,后续访问没反应,会报错,就像这样:
Exception in thread "main" task-->threadName:pool-1-thread-1 java.util.concurrent.RejectedExecutionException: Task java.util.concurrent.FutureTask@70dea4e rejected from java.util.concurrent.ThreadPoolExecutor@5c647e05[Shutting down, pool size = 1, active threads = 1, queued tasks = 0, completed tasks = 0] at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2063) at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:830) at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1379) at java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:134) at threadPools.zxy.threadPools.zxy.ThreadFuture.main(ThreadFuture.java:14)好好的代码,怎么会报错呢,赶时间开发,最随便查了下,有人说是策略的问题,换个策略就好了,于是就将代码改成:
public class ThreadFuture { private static ThreadPoolExecutor executor = new ThreadPoolExecutor(1, 1, 0, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(),new ThreadPoolExecutor.CallerRunsPolicy()); public static void main(String[] args) { //模仿多次客户端请求 for (int i = 0; i < 10; i++) { executor.submit(new Callable<String>() { public String call() throws Exception { System.out.println("task-->threadName:" + Thread.currentThread().getName()); Thread.sleep(1000); return null; } }); executor.shutdown(); } } }
测了一下,现在是不报错了,但是客户端的十次请求,只有第一次访问有效,后来的访问全部没有。这还不是问题的解决啊。转而,想了下,会不会是executor.shutdown()的问题呢,可是很多人都说用完要关掉的啊,要不然不是每次访问都会新增很多线程吗!
too native! 这就是对线程池了解太浅了
其实,shutdown()方法就是关闭线程池,但其实准确来说,shutdown方法是已在运行的线程和队列中的线程可以继续运行,但是新加入的线程会被拒绝,因为,线程池已经说了,我要关闭了,就如同超市晚上关门,我不好意思敢客人们出来,你们继续买,但是新的客人我是不会在放进去了,因为最后的客人买完东西,我就要关门了。
所以,盲目的改策略没有任何用,因为是线程池已经关闭了。
什么时候,shutdown()呢,这里有个问题就是,你为什么需要线程池。
其实,线程池的诞生就是因为,在大量访问进来的时候,不断的new thread(),会造成急剧的性能损失,而且,也不能对线程很方便的管理。就如同,一个公司,在一个月的某个时刻非常的忙,有100个任务,于是,公司在这个时候飞快的招了新的员工,在办完任务,就把100个员工全开除了,这显然是非常不合理的。
线程池的作用就是,在一个公司招了一个人事主管,这个人事主管招了帮忙招了5个人,在100个任务来的时候,给每人一个任务,剩余的95个任务放在任务清单表里,一个一个分配着做完。在不忙的时候,让这五个人挂在哪里休息,或者设置keepAliveTime,有一段时间没活,还可以开除几个节省资源maximumPoolSize,只保留核心员工corePoolSize。
刚刚的代码,在第一次执行以后,就把人事主管开除了,后续任务再进来,线程池都关闭了(公司都没人了),谁干活呢?
所以,平时在用main方法的时候调用shutdown()是因为正常执行结束后,线程池也就没用了,但是服务器是一直运行的,shutdown要慎重啊,后续的代码,把shutdown去掉以后,服务也就正常执行了,但这也引起了我对线程池的兴趣。
线程池的各个参数到底是什么意思呢,各个方法的调用和结束又经历了哪些过程呢?