Java バッチのエラーハンドリングを3つの戦略で実装する方法

import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.logging.Logger;

public class BatchErrorHandling {

    public enum ErrorPolicy { FAIL_FAST, CONTINUE, SKIP_LIMIT }

    public interface RecordProcessor { void process(String record) throws Exception; }

    public static class ErrorHandler {
        private static final Logger LOGGER = Logger.getLogger(ErrorHandler.class.getName());
        private final ErrorPolicy policy;
        private final int maxSkips;
        private int skipCount;
        private final List<String> skipped = new ArrayList<String>();

        public ErrorHandler(ErrorPolicy policy, int maxSkips) {
            this.policy = policy; this.maxSkips = maxSkips;
        }

        public void handle(int lineNum, String record, Exception e) {
            switch (policy) {
                case FAIL_FAST:
                    LOGGER.severe("行" + lineNum + "で中断: " + e.getMessage());
                    throw new RuntimeException("行" + lineNum, e);
                case CONTINUE:
                    LOGGER.warning("行" + lineNum + "スキップ: " + e.getMessage());
                    skipped.add(lineNum + ":" + record);
                    break;
                case SKIP_LIMIT:
                    skipCount++;
                    skipped.add(lineNum + ":" + record);
                    if (skipCount > maxSkips) throw new RuntimeException("スキップ上限超過", e);
                    LOGGER.warning("行" + lineNum + "スキップ(" + skipCount + "/" + maxSkips + ")");
                    break;
            }
        }
        public int getSkipCount() { return skipCount; }
        public List<String> getSkipped() { return skipped; }
    }

    public static int processRecords(List<String> records, RecordProcessor proc, ErrorHandler handler) {
        int success = 0;
        for (int i = 0; i < records.size(); i++) {
            try { proc.process(records.get(i)); success++; }
            catch (Exception e) { handler.handle(i + 1, records.get(i), e); }
        }
        return success;
    }

    public static void main(String[] args) {
        List<String> lines = Arrays.asList("1001,田中,50000", "1002,鈴木,INVALID", "1003,佐藤,30000", "1004,山田,-500", "1005,高橋,45000");
        RecordProcessor proc = new RecordProcessor() {
            @Override public void process(String record) throws Exception {
                String[] f = record.split(",");
                int amount = Integer.parseInt(f[2]);
                if (amount < 0) throw new IllegalArgumentException("金額が負数: " + amount);
                System.out.println("処理: " + f[1] + " / " + amount + "円");
            }
        };
        ErrorHandler handler = new ErrorHandler(ErrorPolicy.SKIP_LIMIT, 3);
        int ok = processRecords(lines, proc, handler);
        System.out.println("成功: " + ok + " / スキップ: " + handler.getSkipCount());
    }
}