1.线上服务大量请求失败问题出现,查看服务器各项参数正常,网络正常,其他服务正常;
2.于是使用jstack分析线程信息:
(1)获取java服务pid
(2) jstack -l pid > jstack.log输出线程信息:
java.lang.Thread.State: WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <********> (a java.util.concurrent.FutureTask$Sync) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:156) at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:811) at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedInterruptibly(AbstractQueuedSynchronizer.java:969) at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireSharedInterruptibly(AbstractQueuedSynchronizer.java:1281) at java.util.concurrent.FutureTask$Sync.innerGet(FutureTask.java:218)(3)线程处于等待状态,然后查看有很多该信息,定位到业务代码,发现使用了线程的submit方法,并且方法实现中又多次使用了submit方法;目的是想多线程处理拿到多个接口统一接口进行合并返回;
(4)然后发现他们使用了同一个静态的线程池对象产生线程,发现参数中问题出在了corePoolSize;
(5)尝试使用测试代码来重现死锁问题;
@Test public void dealLock() throws ExecutionException, InterruptedException { ThreadPoolExecutor pool = new ThreadPoolExecutor(1, 10, 20 , TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(100), new ThreadPoolExecutor.CallerRunsPolicy()); Future<String> submit1 = pool.submit(() -> { Future<String> submit2 = pool.submit(() -> { System.out.println("我是线程2"); return "线程2"; }); String s2 = null; try { s2 = submit2.get(); } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); } System.out.println("我是线程1"); return s2; }); System.out.println("开始执行线程"); String s = submit1.get(); System.out.println(s); }以上只打印了 开始执行线程,然后就卡住了;如果将corePoolSize设为2则正常;
(6)解释原因:
因为核心线程设为1,所以每次处理任务同时最多只有一个线程工作,虽然最大线程数设置为了10,但是仅当任务塞满队列后才会启用新线程;
所以此时当线程1执行外层submit方法时,由于依赖于内部submit的执行结果,但是内部方法又没有足够的核心线程去执行,所以线程1永远无法执行完成,造成死锁;
我想解决方法你应该知道了~
