Параллелизм — важнейший аспект современной разработки программного обеспечения, обеспечивающий эффективное использование системных ресурсов и повышение скорости реагирования приложений. В Java платформа ExecutorService предоставляет API высокого уровня для одновременного управления и выполнения задач. В этой статье мы рассмотрим различные методы выполнения выполняемых задач с помощью ExecutorService, включая примеры кода и пояснения.

1. Отправка выполняемой задачи.
   Самый простой способ выполнить задачу с помощью ExecutorService — отправить объект Runnable. ExecutorService отвечает за управление пулом потоков и выполнение задачи. Вот пример:

ExecutorService executor = Executors.newFixedThreadPool(10);
executor.submit(new RunnableTask());

2. Отправка вызываемой задачи.
   Если ваша задача требует возвращаемого значения или генерирует исключение, вы можете использовать интерфейс Callable вместо интерфейса Runnable. Вызываемые задачи передаются с помощью метода submit, который возвращает объект Future, представляющий результат задачи. Вот пример:

ExecutorService executor = Executors.newFixedThreadPool(10);
Future<String> future = executor.submit(new CallableTask());
String result = future.get(); // Blocking call to retrieve the task's result

3. Параллельное выполнение нескольких задач.
   ExecutorService позволяет выполнять несколько задач одновременно, отправляя их пакетно с помощью метода invokeAll. Этот метод возвращает список объектов Future, которые можно использовать для получения результатов каждой задачи. Вот пример:

ExecutorService executor = Executors.newFixedThreadPool(10);
List<Callable<String>> tasks = Arrays.asList(task1, task2, task3);
List<Future<String>> futures = executor.invokeAll(tasks);
for (Future<String> future : futures) {
    String result = future.get(); // Retrieve the result of each task
    // Handle the result as needed
}

4. Выполнение задач с таймаутом.
   В некоторых сценариях может потребоваться ограничить время выполнения задачи. ExecutorService предоставляет метод invokeAny, который позволяет выполнять несколько задач и получать результат первой завершенной задачи. Вы можете указать значение тайм-аута, чтобы ограничить время выполнения. Вот пример:

ExecutorService executor = Executors.newFixedThreadPool(10);
List<Callable<String>> tasks = Arrays.asList(task1, task2, task3);
String result = executor.invokeAny(tasks, 5, TimeUnit.SECONDS);
// Handle the result of the first completed task

В этой статье мы рассмотрели различные методы выполнения выполняемых задач с использованием ExecutorService в Java. Мы рассмотрели отправку задач Runnable и Callable, параллельное выполнение задач и настройку тайм-аутов для выполнения задач. Понимание этих концепций и эффективное использование ExecutorService может значительно повысить производительность и масштабируемость ваших параллельных приложений.