|
|
@ -179,10 +179,6 @@ public class MasterSchedulerService extends Thread { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
private List<ProcessInstance> command2ProcessInstance(List<Command> commands) { |
|
|
|
private List<ProcessInstance> command2ProcessInstance(List<Command> commands) { |
|
|
|
if (CollectionUtils.isEmpty(commands)) { |
|
|
|
|
|
|
|
return null; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
List<ProcessInstance> processInstances = new ArrayList<>(commands.size()); |
|
|
|
List<ProcessInstance> processInstances = new ArrayList<>(commands.size()); |
|
|
|
CountDownLatch latch = new CountDownLatch(commands.size()); |
|
|
|
CountDownLatch latch = new CountDownLatch(commands.size()); |
|
|
|
for (final Command command : commands) { |
|
|
|
for (final Command command : commands) { |
|
|
|