130

私は、Javaアプリケーションが堅牢になるために合理的な手順を踏んでいることを確認しようとしています。その一部には、正常にシャットダウンすることが含まれます。私はシャットダウンフックについて読んでいますが、実際にそれらを使用する方法を実際に理解していません。

そこに実用的な例はありますか？

以下のような非常に単純なアプリケーションがあり、ファイルに10から1行に、100のバッチで数値を書き込み、プログラムが中断された場合に特定のバッチが終了することを確認したいとします。シャットダウンフックを登録する方法はわかりますが、それをアプリケーションに統合する方法がわかりません。助言がありますか？

package com.example.test.concurrency;

import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.PrintWriter;

public class GracefulShutdownTest1 {
    final private int N;
    final private File f;
    public GracefulShutdownTest1(File f, int N) { this.f=f; this.N = N; }

    public void run()
    {
        PrintWriter pw = null;
        try {
            FileOutputStream fos = new FileOutputStream(this.f);
            pw = new PrintWriter(fos);
            for (int i = 0; i < N; ++i)
                writeBatch(pw, i);
        }
        catch (FileNotFoundException e) {
            e.printStackTrace();
        }
        finally
        {
            pw.close();
        }       
    }

    private void writeBatch(PrintWriter pw, int i) {
        for (int j = 0; j < 100; ++j)
        {
            int k = i*100+j;
            pw.write(Integer.toString(k));
            if ((j+1)%10 == 0)
                pw.write('\n');
            else
                pw.write(' ');
        }
    }

    static public void main(String[] args)
    {
        if (args.length < 2)
        {
            System.out.println("args = [file] [N] "
                    +"where file = output filename, N=batch count");
        }
        else
        {
            new GracefulShutdownTest1(
                    new File(args[0]), 
                    Integer.parseInt(args[1])
            ).run();
        }
    }
}
4

2 に答える 2

168

次のことができます。

  • シャットダウンフックでAtomicBoolean（または揮発性ブール値）の「keepRunning」をfalseに設定します
  • （オプションで.interrupt、動作中のスレッドが何らかのブロッキング呼び出しでデータを待機している場合）
  • writeBatch作業スレッドでメソッドを呼び出して、作業スレッド（この場合は実行中）が終了するのを待ちますThread.join()。
  • プログラムを終了します

いくつかの大ざっぱなコード：

  • 追加するstatic volatile boolean keepRunning = true;

  • run（）で、次のように変更します

    for (int i = 0; i < N && keepRunning; ++i)
    writeBatch(pw, i);

  • main（）に次を追加します。

    final Thread mainThread = Thread.currentThread();
Runtime.getRuntime().addShutdownHook(new Thread() {
    public void run() {
        keepRunning = false;
        mainThread.join();
    }
});

これが、ターミナルで「Control-Cを押したときにすべてのクライアントを拒否する」という優雅な方法です。

ドキュメントから：

仮想マシンがシャットダウンシーケンスを開始すると、登録されているすべてのシャットダウンフックが不特定の順序で開始され、同時に実行されます。すべてのフックが終了すると、終了時のファイナライズが有効になっている場合は、呼び出されていないすべてのファイナライザーが実行されます。最後に、仮想マシンは停止します。

つまり、シャットダウンフックは、フックが終了する（run（）メソッドから返される）までJVMを実行し続けます。

于 2010-05-27T14:31:07.710 に答える
-10

シャットダウンフックは、Runtime.addShutdownHook（）に登録されている未起動のスレッドです。JVMは、シャットダウンフックが開始される順序を保証しません。詳細については、http： //techno-terminal.blogspot.in/2015/08を参照してください。 /shutdown-hooks.html

于 2015-08-30T09:42:40.297 に答える