子線程任務(wù)發(fā)生異常時主線程事務(wù)回滾示例過程
一、提出問題
最近有一位朋友問了我這樣一個問題,問題的截圖如下:
這個問題問的相對比較籠統(tǒng),我來稍微詳細(xì)的描述下:主線程向線程池提交了一個任務(wù),如果執(zhí)行這個任務(wù)過程中發(fā)生了異常,如何讓主線程捕獲到該異常并且進行事務(wù)的回滾。
二、主線程與子線程
先來看看基礎(chǔ),下圖體現(xiàn)了兩種線程的運行方式,
左側(cè)的圖,體現(xiàn)了主線程啟動一個子線程之后,二者互不干擾獨立運行,生死有命,從此你我是路人!
右側(cè)的圖,體現(xiàn)了主線程啟動一個子線程之后繼續(xù)執(zhí)行主線程程序邏輯,在某一節(jié)點通過阻塞的方式來獲取子線程的執(zhí)行結(jié)果。
對于上文中提出的問題,一定是第二種才能解決主線程能夠捕獲子線程執(zhí)行過程中發(fā)生的異常。這里就不得不提一個面試題,實現(xiàn)線程的兩個接口Callable與Runnable之間的區(qū)別:
public interface Callable<V> { V call() throws Exception; }
public interface Runnable { public abstract void run(); }
可以看到call方法帶返回值,run方法沒有返回值。另外call方法可以拋出異常,run方法不可以。很明顯,我們?yōu)榱艘东@或得知子線程的運行結(jié)果,或者運行異常,都應(yīng)該通過Callable接口來實現(xiàn)。
這里我們寫一個ExpSubThread類(子線程異常模擬類),實現(xiàn)Callable接口,不做過多的動作,直接拋出一個空指針異常。
public class ExpSubThread implements Callable { @Override public Object call() throws Exception { throw new NullPointerException(); } }
三、線程池
在面臨線程任務(wù)時,通常我們會預(yù)先建立一個線程池,線程池是預(yù)先規(guī)劃好的n個線程資源的集合。它的好處在于:
執(zhí)行任務(wù)時,不是新建一個線程,而是使用線程池內(nèi)已有的線程資源。任務(wù)執(zhí)行完成也不是銷毀線程,而是將線程資源歸還線程池。所以在一定程度上,節(jié)省了線程創(chuàng)建和銷毀所消耗的資源,達(dá)到線程資源重復(fù)利用的目的。
因為線程池創(chuàng)建的大小是有上限的,所以線程池還有另外的一個作用就是避免線程無限制的被創(chuàng)建,避免應(yīng)用資源無限制的被占用導(dǎo)致的系統(tǒng)宕掉的問題。
常用的線程池有兩種,一種是JDK自帶的,一種是Spring線程池,在Spring環(huán)境下后者常常被使用,二者大同小異。這里我們使用Spring API來構(gòu)建一個線程池。
public ThreadPoolTaskExecutor getThreadPool(){ ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); executor.setMaxPoolSize(100); //線程池最大線程數(shù) executor.setCorePoolSize(50);//線程池核心線程數(shù) executor.setQueueCapacity(50);//任務(wù)隊列的大小 executor.setThreadNamePrefix("test_"); //線程前綴名 executor.initialize(); //線程初始化 return executor; }
四、異常的捕獲
下面是我寫的一個測試用例,在這里它代表了主線程的程序執(zhí)行流程
@Test void subThreadExceptionTest() { try{ //新建子線程對象 ExpSubThread expSubThread = new ExpSubThread(); //構(gòu)建線程池 ThreadPoolTaskExecutor executor = getThreadPool(); //提交子線程任務(wù),submit方法 Future future = executor.submit(expSubThread); //在這里可以做主線程的業(yè)務(wù)其他流程操作 //阻塞等待子線程的執(zhí)行結(jié)果 Object obj = future.get(); }catch (Exception e){ e.printStackTrace(); //事務(wù)回滾 } }
這里需要注意的是使用submit方法提交子線程任務(wù)到線程池內(nèi)執(zhí)行。ThreadPoolTaskExecutor有兩種執(zhí)行線程任務(wù)的方法,一種是execute方法,一種是submit方法。
execute
方法沒有返回值,所以無法判斷任務(wù)是否成功完成,對應(yīng)的線程類實現(xiàn)Runnable接口。
submit
方法有返回值,返回一個Future,對應(yīng)的線程類實現(xiàn)Callable接口。
Future.get()方法達(dá)到了阻塞主線程的目的,從而可以判斷子線程任務(wù)的執(zhí)行結(jié)果,并且get方法可以拋出異常。
V get() throws InterruptedException, ExecutionException;
下面這張圖是上面的測試用例程序程序e.printStackTrace();
的效果,從圖中可以看到兩個Exception異常,一個是我們在子線程任務(wù)中以模擬的方式主動拋出的空指針異常,另一個由于空指針引發(fā)的get方法拋出的ExecutionException。
五、事務(wù)的回滾
上文中大家已經(jīng)看到我們通過
- 線程類實現(xiàn)Callable接口,達(dá)到了獲取線程返回值,或者異常拋出的目的。
- submit可以提交線程任務(wù)到線程池,并且可以獲得子線程執(zhí)行結(jié)果的返回值Future。
- Future的get()方法可以獲取子線程執(zhí)行信息,包括異常的拋出。
那么既然我們已經(jīng)可以在主線程內(nèi)感知或catch子線程的異常信息了,下一步主線程的事務(wù)回滾是不是就太簡單了?
jdbc 就conn.rollback()
實現(xiàn)事務(wù)的回滾
spring環(huán)境下使用@Transactional
注解就可以了。
以上就是子線程任務(wù)發(fā)生異常,主線程事務(wù)如何回滾的詳細(xì)內(nèi)容,更多關(guān)于子線程任務(wù)發(fā)生異常主線程事務(wù)如何回滾的資料請關(guān)注腳本之家其它相關(guān)文章!
相關(guān)文章
SpringBoot選擇自有bean優(yōu)先加載實現(xiàn)方法
在一些需求中,可能存在某些場景,比如先加載自己的bean,然后自己的bean做一些DB操作,初始化配置問題,然后后面的bean基于這個配置文件,繼續(xù)做其他的業(yè)務(wù)邏輯。因此有了本文的這個題目2023-03-03java8如何用Stream查List對象某屬性是否有重復(fù)
這篇文章主要介紹了java8如何用Stream查List對象某屬性是否有重復(fù)的操作,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2021-09-09SpringBoot實現(xiàn)動態(tài)多線程并發(fā)定時任務(wù)
這篇文章主要為大家詳細(xì)介紹了SpringBoot實現(xiàn)動態(tài)多線程并發(fā)定時任務(wù),文中示例代碼介紹的非常詳細(xì),具有一定的參考價值,感興趣的小伙伴們可以參考一下2021-05-05mybatis的映射xml中動態(tài)設(shè)置orderby方式
這篇文章主要介紹了mybatis的映射xml中動態(tài)設(shè)置orderby方式,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2021-11-11Java中FTPClient上傳中文目錄、中文文件名亂碼問題解決方法
這篇文章主要介紹了Java中FTPClient上傳中文目錄、中文文件名亂碼問題解決方法,本文使用apache-commons-net工具包時遇到這個問題,解決方法很簡單,需要的朋友可以參考下2015-05-05