Для bulk insert в параллельном режиме в Java часто используют ExecutorService. Это интерфейс для управления пулом потоков, который позволяет выполнять задачи асинхронно.

Механизм работы:

Создаётся пул потоков, например, Executors.newFixedThreadPool(n).
Задачи (например, вставка частей данных) создаются как объекты Runnable или Callable.
Эти задачи передаются в ExecutorService через методы submit() или execute().

Откуда ExecutorService берёт задания?

Задания помещаются в внутреннюю очередь задач (task queue) при вызове submit().
Потоки из пула берут задачи из этой очереди и выполняют их.

Пример:

ExecutorService executor = Executors.newFixedThreadPool(4);

for (List<Data> chunk : dataChunks) {
    executor.submit(() -> {
        // bulk insert chunk
    });
}

executor.shutdown();
executor.awaitTermination(1, TimeUnit.HOURS);

Таким образом, ExecutorService управляет очередью задач и пулом потоков, обеспечивая параллельное выполнение bulk insert.

Какие механизмы параллельности использовать для bulk insert? Откуда ExecutorService будет брать задания?