uncaughtExceptionメソッドでサブスレッドの例外発生をハンドリングする

void uncaughtException(Thread thread,Throwable t)

public class DeleteThread extends AbstDataUpdateThread{
    
    (中略)

    /** 
     * データを削除します。
     */
    public void run(){
        
        logProcess( true ); // 処理進行ログ
        // ここで削除処理を実行(サンプルのため、実装なし)
        
        int tmp = 2/0;  //わざとランライム例外を発生させる。

        // スレッドが所属するスレッドグループへの参照を取得
        DataUpdateThreadGroup manThreadGrp =
            (DataUpdateThreadGroup)getThreadGroup();
        manThreadGrp.incrementDelete(); // 削除件数を加算
        
        logProcess( false ); // 処理進行ログ
        
    }
}

public abstract class AbstDataUpdateThread extends Thread{
    /**
     * コンストラクタ
     * @param threadGroup スレッドが所属するスレッドグループ
     * @param threadPrefix スレッド名につけるプレフィックス
     */
    public AbstDataUpdateThread(
        ThreadGroup threadGroup,String threadPrefix){
        super( threadGroup , threadPrefix + "_" + 
            (new SimpleDateFormat("yyyymmddhhmmssSSS") )
            .format(new Date() ) );
    }
    
    /** 対象データ */
    protected String data = null;
    
    /**
     * @param data The data to set.
     */
    public void setData(String data) {
        this.data = data;
    }
}

/**
 * 所属するThreadの実行管理、
 * 新規登録・更新・削除の更新件数の管理を行うクラスです。
 */
public class DataUpdateThreadGroup extends ThreadGroup{

    (中略)
    /** エラーが起こったかどうかの真偽値 */
    boolean errorOccured = false;

    (中略)
    
    /** 
     * スレッド内でcatchされていない例外をハンドリングします。
     */
    public void uncaughtException(Thread t, Throwable e) {
        
        errLogger.error( " Exception Occured at " +
            t.getName() , e );
        this.errorOccured = true;
    }

/**
 * 全体の処理フローを制御します。
 */
public void exec(String fileNm)
    throws UnsupportedEncodingException,FileNotFoundException,
    IOException,InterruptedException{
    
    
    BufferedReader br = null; 
    
    try {
        br = new BufferedReader(new InputStreamReader(
            new FileInputStream(new File( fileNm )),"Shift_JIS" ) );
        // データ処理用スレッドが属するスレッドグループの生成
        DataUpdateThreadGroup manageTG =
            new DataUpdateThreadGroup( "manageTG" );
        String line = null;
        
        //----------------------------------------------
        // ファイルを全て読み込むまで処理を続けます。
        //----------------------------------------------
        while( ( line = br.readLine() ) != null ){

            // サブスレッド内でエラーがあった場合、
            // 起動した全てのスレッドが終了するのを待って
            // 全体の処理を停止します。
            if ( manageTG.isErrorOccured() ) {
                waitThreadEnd(manageTG);
                errLogger.error( "Process End because of Error" );
                System.exit( 0 );
            }
            
            String[] csvdata = line.split( "," ); // CSVデータ解析
            
            // １カラム目の値に対応したスレッドを起動します。
            AbstDataUpdateThread commonThread =
                makeThread(manageTG,csvdata[0]);
            commonThread.setData(csvdata[1]);
            commonThread.start();

            // 分かりやすいサンプルにするため、１秒停止
            Thread.sleep( 1000 );          
            
        }
        //----------------------------------------------
        // 起動した全てのスレッドが終了するのを待ちます。
        //----------------------------------------------
        waitThreadEnd(manageTG);
        cntLogger.info( 
                "新規:" + manageTG.getCreateCnt() + 
                "/更新:" + manageTG.getUpdateCnt() + 
                "/削除:" + manageTG.getDeleteCnt() );
        
        
    }finally{
        if ( br != null) br.close();
    }
    
}

/**
 * スレッドグループ内で起動中のスレッド数が0になるまで待機します。
 */
private void waitThreadEnd(ThreadGroup threadGroup)
    throws InterruptedException{
    while ( true ){
        if ( threadGroup.activeCount() == 0 ) break;

        // 全スレッドが終了していない場合は１秒待つ
        Thread.sleep( 1000 );
    }         
    
}

n,新規データ1
n,新規データ2
u,更新データ1
u,更新データ2
d,削除データ3
u,更新データ3
u,更新データ4

log4j.appender.errorMail.SMTPHost=xxx.xxx.xxx.xxx
(メール送信に使用するSMTPサーバー)

log4j.appender.errorMail.From=xxx@xxx.xxx
(エラーメール送信元メールアドレス)

log4j.appender.errorMail.To=xxx@xxx.xxx
(エラーメール送信先メールアドレス)