公司在使用定時(shí)任務(wù)的時(shí)候，使用的是spring scheduled。

代碼如下：

@EnableScheduling
public class TaskFileScheduleService {


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

某天，接到領(lǐng)導(dǎo)的電話，說生產(chǎn)環(huán)境的定時(shí)任務(wù)不跑了，趕緊給看看~
做為一名負(fù)責(zé)人的程序員，趕緊放下手中泡面，遠(yuǎn)程到公司的電腦~
線程卡死這種問題，第一步當(dāng)然是將jvm中的heap dump和thread dump導(dǎo)出來~
經(jīng)過簡單分析，thread dump中某個(gè)線程確實(shí)一直處理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這個(gè)方法卡死，導(dǎo)致線程一直處于running狀態(tài)。

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

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

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

現(xiàn)在只剩一條路，怎么在任務(wù)1卡死的時(shí)候，任務(wù)2可以按他自己的周期執(zhí)行，且任務(wù)1也按照固定周期執(zhí)行，不會(huì)因?yàn)槟炒稳蝿?wù)1卡死導(dǎo)致后續(xù)的定時(shí)任務(wù)出現(xiàn)問題！

方法一：

添加配置

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

這個(gè)方法，在程序啟動(dòng)后，會(huì)逐步啟動(dòng)50個(gè)線程，放在線程池中。每個(gè)定時(shí)任務(wù)會(huì)占用1個(gè)線程。但是相同的定時(shí)任務(wù)，執(zhí)行的時(shí)候，還是在同一個(gè)線程中。
例如，程序啟動(dòng)，每個(gè)定時(shí)任務(wù)占用一個(gè)線程。任務(wù)1開始執(zhí)行，任務(wù)2也開始執(zhí)行。如果任務(wù)1卡死了，那么下個(gè)周期，任務(wù)1還是處理卡死狀態(tài)，任務(wù)2可以正常執(zhí)行。也就是說，任務(wù)1某一次卡死了，不會(huì)影響其他線程，但是他自己本身這個(gè)定時(shí)任務(wù)會(huì)一直等待上一次任務(wù)執(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(){
? ? .......
? ? }

這種方法，每次定時(shí)任務(wù)啟動(dòng)的時(shí)候，都會(huì)創(chuàng)建一個(gè)單獨(dú)的線程來處理。也就是說同一個(gè)定時(shí)任務(wù)也會(huì)啟動(dòng)多個(gè)線程處理。
例如：任務(wù)1和任務(wù)2一起處理，但是線程1卡死了，任務(wù)2是可以正常執(zhí)行的。且下個(gè)周期，任務(wù)1還是會(huì)正常執(zhí)行，不會(huì)因?yàn)樯弦淮慰ㄋ懒?，影響任?wù)1。
但是任務(wù)1中的卡死線程越來越多，會(huì)導(dǎo)致50個(gè)線程池占滿，還是會(huì)影響到定時(shí)任務(wù)。
這時(shí)候，可能會(huì)幾個(gè)月發(fā)生一次~到時(shí)候再重啟就行了！

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

最新評論