一、提出問(wèn)題

最近有一位朋友問(wèn)了我這樣一個(gè)問(wèn)題，問(wèn)題的截圖如下：

這個(gè)問(wèn)題問(wèn)的相對(duì)比較籠統(tǒng)，我來(lái)稍微詳細(xì)的描述下：主線(xiàn)程向線(xiàn)程池提交了一個(gè)任務(wù)，如果執(zhí)行這個(gè)任務(wù)過(guò)程中發(fā)生了異常，如何讓主線(xiàn)程捕獲到該異常并且進(jìn)行事務(wù)的回滾。

二、主線(xiàn)程與子線(xiàn)程

先來(lái)看看基礎(chǔ)，下圖體現(xiàn)了兩種線(xiàn)程的運(yùn)行方式，

• 左側(cè)的圖，體現(xiàn)了主線(xiàn)程啟動(dòng)一個(gè)子線(xiàn)程之后，二者互不干擾獨(dú)立運(yùn)行，生死有命，從此你我是路人！
• 右側(cè)的圖，體現(xiàn)了主線(xiàn)程啟動(dòng)一個(gè)子線(xiàn)程之后繼續(xù)執(zhí)行主線(xiàn)程程序邏輯，在某一節(jié)點(diǎn)通過(guò)阻塞的方式來(lái)獲取子線(xiàn)程的執(zhí)行結(jié)果。

對(duì)于上文中提出的問(wèn)題，一定是第二種才能解決主線(xiàn)程能夠捕獲子線(xiàn)程執(zhí)行過(guò)程中發(fā)生的異常。這里就不得不提一個(gè)面試題，實(shí)現(xiàn)線(xiàn)程的兩個(gè)接口Callable與Runnable之間的區(qū)別：

public interface Callable<V> {
    V call() throws Exception;
}

public interface Runnable {
    public abstract void run();
}

可以看到call方法帶返回值，run方法沒(méi)有返回值。另外call方法可以?huà)伋霎惓?，run方法不可以。很明顯，我們?yōu)榱艘东@或得知子線(xiàn)程的運(yùn)行結(jié)果，或者運(yùn)行異常，都應(yīng)該通過(guò)Callable接口來(lái)實(shí)現(xiàn)。

這里我們寫(xiě)一個(gè)ExpSubThread類(lèi)(子線(xiàn)程異常模擬類(lèi))，實(shí)現(xiàn)Callable接口，不做過(guò)多的動(dòng)作，直接拋出一個(gè)空指針異常。

public class ExpSubThread implements Callable {
    @Override
    public Object call() throws Exception {
        throw new NullPointerException();
    }
}

三、線(xiàn)程池

在面臨線(xiàn)程任務(wù)時(shí)，通常我們會(huì)預(yù)先建立一個(gè)線(xiàn)程池，線(xiàn)程池是預(yù)先規(guī)劃好的n個(gè)線(xiàn)程資源的集合。它的好處在于：

• 執(zhí)行任務(wù)時(shí)，不是新建一個(gè)線(xiàn)程，而是使用線(xiàn)程池內(nèi)已有的線(xiàn)程資源。任務(wù)執(zhí)行完成也不是銷(xiāo)毀線(xiàn)程，而是將線(xiàn)程資源歸還線(xiàn)程池。所以在一定程度上，節(jié)省了線(xiàn)程創(chuàng)建和銷(xiāo)毀所消耗的資源，達(dá)到線(xiàn)程資源重復(fù)利用的目的。
• 因?yàn)榫€(xiàn)程池創(chuàng)建的大小是有上限的，所以線(xiàn)程池還有另外的一個(gè)作用就是避免線(xiàn)程無(wú)限制的被創(chuàng)建，避免應(yīng)用資源無(wú)限制的被占用導(dǎo)致的系統(tǒng)宕掉的問(wèn)題。

常用的線(xiàn)程池有兩種，一種是JDK自帶的，一種是Spring線(xiàn)程池，在Spring環(huán)境下后者常常被使用，二者大同小異。這里我們使用Spring API來(lái)構(gòu)建一個(gè)線(xiàn)程池。

public ThreadPoolTaskExecutor getThreadPool(){
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setMaxPoolSize(100);  //線(xiàn)程池最大線(xiàn)程數(shù)
        executor.setCorePoolSize(50);//線(xiàn)程池核心線(xiàn)程數(shù)
        executor.setQueueCapacity(50);//任務(wù)隊(duì)列的大小
        executor.setThreadNamePrefix("test_"); //線(xiàn)程前綴名
        executor.initialize(); //線(xiàn)程初始化
        return executor;
}

四、異常的捕獲

下面是我寫(xiě)的一個(gè)測(cè)試用例，在這里它代表了主線(xiàn)程的程序執(zhí)行流程

@Test
void subThreadExceptionTest() {
        try{
            //新建子線(xiàn)程對(duì)象
            ExpSubThread expSubThread = new ExpSubThread();
            //構(gòu)建線(xiàn)程池
            ThreadPoolTaskExecutor executor = getThreadPool();
            //提交子線(xiàn)程任務(wù)，submit方法
            Future future = executor.submit(expSubThread);
            //在這里可以做主線(xiàn)程的業(yè)務(wù)其他流程操作
            //阻塞等待子線(xiàn)程的執(zhí)行結(jié)果
            Object obj = future.get();  
        }catch (Exception e){
            e.printStackTrace();
            //事務(wù)回滾
        }
}

這里需要注意的是使用submit方法提交子線(xiàn)程任務(wù)到線(xiàn)程池內(nèi)執(zhí)行。ThreadPoolTaskExecutor有兩種執(zhí)行線(xiàn)程任務(wù)的方法，一種是execute方法，一種是submit方法。

• execute方法沒(méi)有返回值，所以無(wú)法判斷任務(wù)是否成功完成，對(duì)應(yīng)的線(xiàn)程類(lèi)實(shí)現(xiàn)Runnable接口。
• submit方法有返回值，返回一個(gè)Future，對(duì)應(yīng)的線(xiàn)程類(lèi)實(shí)現(xiàn)Callable接口。

Future.get()方法達(dá)到了阻塞主線(xiàn)程的目的，從而可以判斷子線(xiàn)程任務(wù)的執(zhí)行結(jié)果，并且get方法可以?huà)伋霎惓！?/p>

    V get() throws InterruptedException, ExecutionException;

下面這張圖是上面的測(cè)試用例程序程序e.printStackTrace();的效果，從圖中可以看到兩個(gè)Exception異常，一個(gè)是我們?cè)谧泳€(xiàn)程任務(wù)中以模擬的方式主動(dòng)拋出的空指針異常，另一個(gè)由于空指針引發(fā)的get方法拋出的ExecutionException。

五、事務(wù)的回滾

上文中大家已經(jīng)看到我們通過(guò)

• 線(xiàn)程類(lèi)實(shí)現(xiàn)Callable接口，達(dá)到了獲取線(xiàn)程返回值，或者異常拋出的目的。
• submit可以提交線(xiàn)程任務(wù)到線(xiàn)程池，并且可以獲得子線(xiàn)程執(zhí)行結(jié)果的返回值Future。
• Future的get()方法可以獲取子線(xiàn)程執(zhí)行信息，包括異常的拋出。

那么既然我們已經(jīng)可以在主線(xiàn)程內(nèi)感知或catch子線(xiàn)程的異常信息了，下一步主線(xiàn)程的事務(wù)回滾是不是就太簡(jiǎn)單了？

• jdbc 就conn.rollback()實(shí)現(xiàn)事務(wù)的回滾
• spring環(huán)境下使用@Transactional注解就可以了。

到此這篇關(guān)于詳解Java子線(xiàn)程異常時(shí)主線(xiàn)程事務(wù)如何回滾的文章就介紹到這了,更多相關(guān)Java 事務(wù)的回滾內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論