Это вопрос проектирования относительно реализации конвейера. Вот моя наивная реализация.
Интерфейс для отдельных шагов / стадий в конвейере:
public interface Step<T, U> {
public U execute(T input);
}
Конкретные реализации шагов / этапов в конвейере:
public class StepOne implements Step<Integer, Integer> {
@Override
public Integer execute(Integer input) {
return input + 100;
}
}
public class StepTwo implements Step<Integer, Integer> {
@Override
public Integer execute(Integer input) {
return input + 500;
}
}
public class StepThree implements Step<Integer, String> {
@Override
public String execute(Integer input) {
return "The final amount is " + input;
}
}
Класс конвейера будет удерживать / регистрировать шаги в конвейере и выполнять их один за другим:
public class Pipeline {
private List<Step> pipelineSteps = new ArrayList<>();
private Object firstStepInput = 100;
public void addStep(Step step) {
pipelineSteps.add(step);
}
public void execute() {
for (Step step : pipelineSteps) {
Object out = step.execute(firstStepInput);
firstStepInput = out;
}
}
}
Программа Diver для выполнения конвейера:
public class Main {
public static void main(String[] args) {
Pipeline pipeline = new Pipeline();
pipeline.addStep(new StepOne());
pipeline.addStep(new StepTwo());
pipeline.addStep(new StepThree());
pipeline.execute();
}
}
Однако, как видите, наивная реализация имеет множество ограничений.
Один из основных состоит в том, что, поскольку требуется, чтобы выходные данные каждого шага могли быть любого типа, наивная реализация не является типобезопасной (метод execute в классе Pipeline). Если я неправильно подключу шаги в конвейере, приложение выйдет из строя.
Может ли кто-нибудь помочь мне разработать решение, добавив к тому, что я закодировал, или указать мне на уже существующий шаблон для решения этой проблемы?
