在Java中，對于數據的批量處理，可以使用多線程、隊列和數據庫事務等技術。這里我們將介紹一種使用ExecutorService和BlockingQueue實現的方法。

1. 首先，創建一個BlockingQueue來存儲待處理的數據。BlockingQueue是一個線程安全的隊列，可以用于在生產者和消費者之間傳遞數據。

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;

public class DataBatchProcessor {
    private static final int QUEUE_CAPACITY = 100;
    private BlockingQueue<Data> dataQueue = new LinkedBlockingQueue<>(QUEUE_CAPACITY);
}

2. 創建一個Runnable任務來處理數據。在這個任務中，我們將從隊列中獲取數據并進行處理。

public class DataProcessor implements Runnable {
    private BlockingQueue<Data> dataQueue;

    public DataProcessor(BlockingQueue<Data> dataQueue) {
        this.dataQueue = dataQueue;
    }

    @Override
    public void run() {
        while (true) {
            try {
                Data data = dataQueue.take();
                processData(data);
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
                break;
            }
        }
    }

    private void processData(Data data) {
        // 處理數據的邏輯
    }
}

3. 使用ExecutorService來管理和執行DataProcessor任務。

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class DataBatchProcessor {
    // ...
    private static final int NUM_PROCESSORS = 4;
    private ExecutorService executorService = Executors.newFixedThreadPool(NUM_PROCESSORS);

    public DataBatchProcessor() {
        for (int i = 0; i < NUM_PROCESSORS; i++) {
            executorService.submit(new DataProcessor(dataQueue));
        }
    }
}

4. 提供一個方法將數據添加到隊列中。

public class DataBatchProcessor {
    // ...
    public void addData(Data data) throws InterruptedException {
        dataQueue.put(data);
    }
}

5. 最后，確保在不再需要時關閉ExecutorService。

public class DataBatchProcessor {
    // ...
    public void shutdown() {
        executorService.shutdown();
    }
}

現在你可以創建一個DataBatchProcessor實例，并使用addData()方法將數據添加到隊列中。數據將被分配給NUM_PROCESSORS個處理器進行處理。當不再需要處理數據時，調用shutdown()方法關閉ExecutorService。