Это вопрос дизайна, связанный с реализацией Pipeline. Ниже приведена моя наивная реализация.
Интерфейс для отдельных шагов/этапов в конвейере:
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;
}
}
}
Программа дайвера для выполнения конвейера:
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). Если произойдет неправильное подключение шагов в конвейере, приложение не будет выполнено.
Может ли кто-нибудь помочь мне разработать решение, добавив к тому, что я закодировал, или указать мне на уже существующий шаблон, чтобы решить эту проблему?
