diff --git a/liteflow-core/src/main/java/com/yomahub/liteflow/entity/flow/ParallelWorker.java b/liteflow-core/src/main/java/com/yomahub/liteflow/entity/flow/ParallelWorker.java deleted file mode 100644 index f5d82f368..000000000 --- a/liteflow-core/src/main/java/com/yomahub/liteflow/entity/flow/ParallelWorker.java +++ /dev/null @@ -1,29 +0,0 @@ -package com.yomahub.liteflow.entity.flow; - -import com.yomahub.liteflow.asynctool.callback.IWorker; -import com.yomahub.liteflow.asynctool.wrapper.WorkerWrapper; - -import java.util.Map; - -public class ParallelWorker implements IWorker { - - private final Executable executableItem; - - private final Integer slotIndex; - - public ParallelWorker(Executable executableItem, Integer slotIndex) { - this.executableItem = executableItem; - this.slotIndex = slotIndex; - } - - @Override - public String action(Void object, Map allWrappers) throws Exception{ - executableItem.execute(slotIndex); - return executableItem.getExecuteName(); - } - - @Override - public String defaultValue() { - return executableItem.getExecuteName(); - } -}