Java の例の詳細な説明: サブスレッドのタスク例外、メインスレッドのトランザクションのロールバック

この記事では、java に関する関連知識を提供します。主に、例外のキャプチャなど、サブスレッド タスクで例外が発生したときにメイン スレッド トランザクションをロールバックする方法に関する関連問題を紹介します。トランザクションのロールバックなどについて、以下で見ていきましょう。

Java ビデオ チュートリアル 」

1. 質問する

メイン スレッドはタスクをスレッド プールに送信しました。このタスクの実行中に例外が発生した場合、メイン スレッドはどのように例外をキャッチしてトランザクションをロールバックできますか?

2. メイン スレッドとサブスレッド

左の図は、メインスレッドがサブスレッドを開始した後、2 つのスレッドが互いに干渉することなく独立して実行されることを示しています。生と死は運命によって決まります。これからは、あなたと私は通行人！
• 右図は、メインスレッドがサブスレッドを開始し、その後メインスレッドのプログラムロジックを実行し続け、あるノードでブロックすることでサブスレッドの実行結果を取得する様子を示しています。

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

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

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

タスクを実行するとき、新しいスレッドは作成されませんが、スレッド プール内の既存のスレッド リソースが使用されます。タスクの実行が完了すると、スレッド リソースは破棄されず、スレッド プールに戻されます。したがって、スレッドの作成と破棄によって消費されるリソースがある程度節約され、スレッド リソースの再利用の目的が達成されます。
• スレッド プールのサイズには上限があるため、スレッド プールのもう 1 つの機能は、無制限のスレッドの作成を回避し、無制限のアプリケーション リソースによって引き起こされるシステム クラッシュを回避することです。

public ThreadPoolTaskExecutor getThreadPool(){
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setMaxPoolSize(100);  //线程池最大线程数
        executor.setCorePoolSize(50);//线程池核心线程数
        executor.setQueueCapacity(50);//任务队列的大小
        executor.setThreadNamePrefix("test_"); //线程前缀名
        executor.initialize(); //线程初始化
        return executor;}

@Testvoid subThreadExceptionTest() {
        try{
            //新建子线程对象
            ExpSubThread expSubThread = new ExpSubThread();
            //构建线程池
            ThreadPoolTaskExecutor executor = getThreadPool();
            //提交子线程任务，submit方法
            Future future = executor.submit(expSubThread);
            //在这里可以做主线程的业务其他流程操作
            //阻塞等待子线程的执行结果
            Object obj = future.get();  
        }catch (Exception e){
            e.printStackTrace();
            //事务回滚
        }}

execute メソッドには戻り値がないため、タスクが正常に完了したかどうかを判断することはできません。対応するスレッド クラスは Runnable インターフェイスを実装します。
• submit メソッドには戻り値があり、Future を返し、対応するスレッド クラスは Callable インターフェイスを実装します。

    V get() throws InterruptedException, ExecutionException;

e.printStackTrace(); の効果です。この図から 2 つの例外がわかります。1 つは子にあることです。 thread タスク内でシミュレートされた方法でアクティブにスローされる null ポインター例外、および null ポインターによって引き起こされる get メソッドによってスローされる別の ExecutionException。

スレッド クラスを通じて Callable インターフェイスを実装しました。 . スレッドの戻り値を取得したり、例外をスローしたりする目的は達成されます。
• Submit はスレッドタスクをスレッドプールに投入し、サブスレッドの実行結果の戻り値 Future を取得できます。
• Future の get() メソッドは、スローされた例外を含む子スレッドの実行情報を取得できます。

• jdbc は conn.rollback() だけでトランザクションのロールバックを実現します
• Spring 環境では @Transactional アノテーションを使用するだけです。

推奨学習: 「Java ビデオ チュートリアル 」

以上がJava の例の詳細な説明: サブスレッドのタスク例外、メインスレッドのトランザクションのロールバックの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。