Как выполнять задачи в ExecutorService последовательно?

Question

У меня есть три потока, которые соединены, то есть второй поток выполняется после первых штампов.

Это код, у меня есть:

public class Main { 
    public static void main(String args[]) throws Exception { 
     final Thread thrdA = new Thread(() -> System.out.println("Message 1")); 
     final Thread thrdB = new Thread(() -> System.out.println("Message 2")); 
     final Thread thrdC = new Thread(() -> System.out.println("Message 3")); 

     thrdA.start(); 
     thrdA.join(); 
     thrdB.start(); 
     thrdB.join(); 
     thrdC.start(); 
     thrdC.join(); 

    } 
} 

Как бы реализовать эту функцию, используя ExecutorService вместо трех объектов нить?

Answer 1

Если вам нужно/нужно выполнить группу заданий один за другим, но в одном потоке, отличном от основного потока приложения, используйте Executors#newSingleThreadExecutor.

ExecutorService es = Executors.newSingleThreadExecutor(); 
es.submit(() -> System.out.println("Message 1")); 
es.submit(() -> System.out.println("Message 2")); 
es.submit(() -> System.out.println("Message 3")); 
es.shutdown(); 

Answer 2

Вы можете контролировать последовательное выполнение потоков с использованием SingleThread ExecutorService методом future.get().

DummyTask Класс

import java.util.concurrent.Callable; 

public class DummyTask implements Callable<Integer> 
{ 

int taskId; 

public DummyTask(int taskId) { 
    this.taskId = taskId; 
} 

@Override 
public Integer call() throws Exception 
{ 
    System.out.println("excuting task... Task Id: " + taskId); 
    return taskId; 
} 

} 

SequentialExecution Класс

package com.amit.executorservice; 

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

public class SequentialExecution 
{ 
public static void main(String[] args) throws InterruptedException, ExecutionException { 

    DummyTask task1 = new DummyTask(1); 
    DummyTask task2 = new DummyTask(2); 
    DummyTask task3 = new DummyTask(3); 
    Future<Integer> result = null; 
    ExecutorService executor = Executors.newSingleThreadExecutor(); 

    result = executor.submit(task1); 
    // future.get() Waits for the task to complete, and then retrieves its result. 
    result.get(); 

    result = executor.submit(task2); 
    // future.get() Waits for the task to complete, and then retrieves its result. 
    result.get(); 

    result = executor.submit(task3); 
    // future.get() Waits for the task to complete, and then retrieves its result. 
    result.get(); 

    executor.shutdown(); 

} 
} 

Выходной

excuting task... Task Id: 1 
excuting task... Task Id: 2 
excuting task... Task Id: 3 

Outpu t всегда будет одинаковым, и вся задача будет выполнена в последовательности.

Answer 3

Если вы уже используете пул потоков в своем приложении, вы можете его повторно использовать с помощью прокси-сервера с нулевым потоком без создания специального однопоточного пула потоков. Одна реализация описана в javadoc section of Executor interface, другой, оптимизированной реализации, в моем репозитории Github CodeSamples.