公司在使用定時任務的時候，使用的是spring scheduled。

代碼如下：

@EnableScheduling
public class TaskFileScheduleService {


? ? @Scheduled(cron="0 */1 * * * ?")
? ? public void task1(){
? ? .......
? ? }
? ??
? ? @Scheduled(cron="0 */1 * * * ?")
? ? public void task2(){
? ? .......
? ? }

某天，接到領(lǐng)導的電話，說生產(chǎn)環(huán)境的定時任務不跑了，趕緊給看看~
做為一名負責人的程序員，趕緊放下手中泡面，遠程到公司的電腦~
線程卡死這種問題，第一步當然是將jvm中的heap dump和thread dump導出來~
經(jīng)過簡單分析，thread dump中某個線程確實一直處理running狀態(tài)，heap dump沒啥問題~
thread dump中的問題線程：

"pool-2-thread-43" #368 prio=5 os_prio=0 tid=0x00005587fd54c800 nid=0x1df runnable [0x00007ff7e2056000]
   java.lang.Thread.State: RUNNABLE
    at java.net.SocketInputStream.socketRead0(Native Method)
    at java.net.SocketInputStream.socketRead(SocketInputStream.java:116)
    at java.net.SocketInputStream.read(SocketInputStream.java:171)
    at java.net.SocketInputStream.read(SocketInputStream.java:141)
    at java.net.SocketInputStream.read(SocketInputStream.java:224)
    at ch.ethz.ssh2.transport.ClientServerHello.readLineRN(ClientServerHello.java:30)
    at ch.ethz.ssh2.transport.ClientServerHello.<init>(ClientServerHello.java:67)
    at ch.ethz.ssh2.transport.TransportManager.initialize(TransportManager.java:455)
    at ch.ethz.ssh2.Connection.connect(Connection.java:643)
    - locked <0x000000074539e0e8> (a ch.ethz.ssh2.Connection)
    at ch.ethz.ssh2.Connection.connect(Connection.java:490)
    - locked <0x000000074539e0e8> (a ch.ethz.ssh2.Connection)
    at com.suneee.yige.medicalserver.common.SSHUtils.connect(SSHUtils.java:24)
    at com.suneee.yige.medicalserver.service.TaskFileScheduleService.getConn(TaskFileScheduleService.java:102)
    at com.suneee.yige.medicalserver.service.TaskFileScheduleService.taskInfo(TaskFileScheduleService.java:108)
    at com.suneee.yige.medicalserver.service.TaskFileScheduleService.task(TaskFileScheduleService.java:74)
    at sun.reflect.GeneratedMethodAccessor295.invoke(Unknown Source)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at org.springframework.scheduling.support.ScheduledMethodRunnable.run(ScheduledMethodRunnable.java:65)
    at org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:54)
    at org.springframework.scheduling.concurrent.ReschedulingRunnable.run(ReschedulingRunnable.java:81)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
    at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
    at java.lang.Thread.run(Thread.java:748)

很明顯，ch.ethz.ssh2.Connection.connect這個方法卡死，導致線程一直處于running狀態(tài)。

由于spring scheduled默認是所有定時任務都在一個線程中執(zhí)行！！這是個大坑?。?！
也就是說定時任務1一直在執(zhí)行，定時任務2一直在等待定時任務1執(zhí)行完成。這就導致了生產(chǎn)上定時任務全部卡死的現(xiàn)象。

問題已經(jīng)很明確了，要么解決ch.ethz.ssh2.Connection.connect卡死的問題，要么解決spring scheduled單線程處理的問題。

首先，想到的是處理ch.ethz.ssh2.Connection.connect卡死的問題，但是經(jīng)過一番查找，發(fā)現(xiàn)這個ssh的工具包很久沒更更新過了，也沒有設(shè)置例如httpclient的超時時間之類的。這就很難辦了！果斷放棄??！

現(xiàn)在只剩一條路，怎么在任務1卡死的時候，任務2可以按他自己的周期執(zhí)行，且任務1也按照固定周期執(zhí)行，不會因為某次任務1卡死導致后續(xù)的定時任務出現(xiàn)問題！

方法一：

添加配置

@Configuration
public class ScheduleConfig implements SchedulingConfigurer {
? ? @Override
? ? public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
? ? ? ? taskRegistrar.setScheduler(Executors.newScheduledThreadPool(50));
? ? }
}

這個方法，在程序啟動后，會逐步啟動50個線程，放在線程池中。每個定時任務會占用1個線程。但是相同的定時任務，執(zhí)行的時候，還是在同一個線程中。
例如，程序啟動，每個定時任務占用一個線程。任務1開始執(zhí)行，任務2也開始執(zhí)行。如果任務1卡死了，那么下個周期，任務1還是處理卡死狀態(tài)，任務2可以正常執(zhí)行。也就是說，任務1某一次卡死了，不會影響其他線程，但是他自己本身這個定時任務會一直等待上一次任務執(zhí)行完成！
這種顯然不行！這也是踩過坑才知道的?。?！

方法二（正解）：

添加配置：

@Configuration
@EnableAsync
public class ScheduleConfig {

? ? @Bean
? ? public TaskScheduler taskScheduler() {
? ? ? ? ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
? ? ? ? taskScheduler.setPoolSize(50);
? ? ? ? return taskScheduler;
? ? }
}

在方法上添加注解@Async

@EnableScheduling
public class TaskFileScheduleService {


? ? @Async
? ? @Scheduled(cron="0 */1 * * * ?")
? ? public void task1(){
? ? .......
? ? }
? ??
? ? @Async
? ? @Scheduled(cron="0 */1 * * * ?")
? ? public void task2(){
? ? .......
? ? }

這種方法，每次定時任務啟動的時候，都會創(chuàng)建一個單獨的線程來處理。也就是說同一個定時任務也會啟動多個線程處理。
例如：任務1和任務2一起處理，但是線程1卡死了，任務2是可以正常執(zhí)行的。且下個周期，任務1還是會正常執(zhí)行，不會因為上一次卡死了，影響任務1。
但是任務1中的卡死線程越來越多，會導致50個線程池占滿，還是會影響到定時任務。
這時候，可能會幾個月發(fā)生一次~到時候再重啟就行了！

到此這篇關(guān)于spring scheduled單線程和多線程使用過程中的大坑的文章就介紹到這了,更多相關(guān)spring scheduled單線程和多線程內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！