首页猿问有限制的运行配置

有限制的运行配置

Java

胡说叔叔 2022-11-30 10:55:10

我对如何继续我的代码有疑问。我的项目是一个在后台一个一个地运行配置的工具。我想为运行配置的数量添加一个限制。例如，如果我有 13 个配置，我想每次运行 5 个配置，所以顺序是：- Running 5 configurations- All 5 configurations done running- Running 5 configurations- All 5 configurations done running- Running 3 configurations- All 3 configurations done running现在的代码，工作如下：public void runConfigurations(List<ConfigStruct> configurations) { for (ConfigStruct configuration : configurations) { try { configuration.run(); } catch (ConfigurationException e) { continue; } }}现在，它一个一个地运行每个配置。该run方法如下所示：public void run() throws ConfigurationException { StringBuffer runCmd = generateGalishFullCommand(GalishFlags.RUN); try { ExternalCommandExecutor.execute(runCmd, "Failed to run " + name, true, true); } catch (IOException e) { throw new ConfigurationException(e.getMessage()); }}外观签名execute如下：public static String execute(final String cmd, final String error, final boolean runInBackground, final boolean retry) throws IOException;起初，我虽然可以不在后台每 5 个配置运行最后一个配置，但它有问题。我不能不在后台执行每 5 个配置的最后一个配置，因为第一个配置可能最后完成。我该如何解决这个问题？编辑：当我打印配置时，它看起来如下：[com.configStructs@3f15dbec, com.configStructs@31d2327e]此外，这configurations是一个列表configStructs。

查看完整描述

2 回答

神不在的星期二

TA贡献1963条经验获得超6个赞

抱歉vesii如果我不完全理解甚至误解你的问题，但你的英语不是很好，即使在你发表评论后我也有问题，看看使用多线程的问题是什么。

无论如何，我建议你让你的ConfigStruct类实现Runnable接口，这很容易，因为它已经有一个run()方法。您只需要摆脱抛出已检查的异常，因此我进一步建议创建ConfigurationException一个RuntimeException您不必在方法签名中声明的异常。

不幸的是，您没有提供完整的MCVE，只有代码片段。所以我必须弥补其余部分才能编译和运行您的代码。我只是添加了一些简单的助手/虚拟类。我的解决方案如下所示：

package de.scrum_master.app;

public enum GalishFlags {

RUN

}

package de.scrum_master.app;

public class ConfigurationException extends RuntimeException {

private static final long serialVersionUID = 1L;

public ConfigurationException(String message, Throwable cause) {

super(message, cause);

}

package de.scrum_master.app;

import java.io.IOException;

public class ExternalCommandExecutor {

public static String execute(final String cmd, final String error, final boolean runInBackground, final boolean retry) throws IOException {

System.out.println("Executing external command: " + cmd);

try {

Thread.sleep(100);

} catch (InterruptedException e) {

e.printStackTrace();

}

return cmd;

}

如您所见，命令执行器在将内容打印到控制台后等待 100 毫秒。如果您希望程序运行得更慢或什至随机化以模拟需要不同时间完成的命令，您也可以将其更改为 1000 毫秒。

现在我们需要一个小的驱动程序应用程序，我们可以在其中生成配置并运行它们。解决你从不同时运行超过 5 个线程的问题的关键是通过创建一个固定的线程池Executors.newFixedThreadPool(5)。其余的应该很容易理解。

package de.scrum_master.app;

import java.io.IOException;

public class ConfigStruct implements Runnable {

private String name;

public ConfigStruct(String name) {

this.name = name;

}

@Override

public void run() {

StringBuffer runCmd = generateGalishFullCommand(GalishFlags.RUN);

try {

ExternalCommandExecutor.execute(runCmd.toString(), "Failed to run " + name, true, true);

} catch (IOException e) {

throw new ConfigurationException(e.getMessage(), e);

}

private StringBuffer generateGalishFullCommand(GalishFlags run) {

return new StringBuffer("Galish full command for ConfigStruct '" + name + "'");

}

package de.scrum_master.app;

import java.util.ArrayList;

import java.util.List;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

import java.util.concurrent.TimeUnit;

public class Application {

public void runConfigurations(List<ConfigStruct> configurations) {

for (ConfigStruct configuration : configurations) {

try {

configuration.run();

} catch (ConfigurationException e) {

continue;

}

public void runConfigurationsThreaded(List<ConfigStruct> configurations) {

ExecutorService executorService = Executors.newFixedThreadPool(5);

for (ConfigStruct configuration : configurations)

executorService.execute(configuration);

executorService.shutdown();

try {

executorService.awaitTermination(30, TimeUnit.SECONDS);

} catch (InterruptedException e) {

e.printStackTrace();

}

public static void main(String[] args) {

List<ConfigStruct> configurations = new ArrayList<>();

for (int i = 1; i <= 13; i++)

configurations.add(new ConfigStruct("Configuration " + i));

long startTime = System.currentTimeMillis();

new Application().runConfigurations(configurations);

System.out.println("Total time (1 thread) = " + (System.currentTimeMillis() - startTime) + " ms");

System.out.println();

startTime = System.currentTimeMillis();

new Application().runConfigurationsThreaded(configurations);

System.out.println("Total time (5 threads) = " + (System.currentTimeMillis() - startTime) + " ms");

}

控制台日志将如下所示：

Executing external command: Galish full command for ConfigStruct 'Configuration 1'

Executing external command: Galish full command for ConfigStruct 'Configuration 2'

Executing external command: Galish full command for ConfigStruct 'Configuration 3'

Executing external command: Galish full command for ConfigStruct 'Configuration 4'

Executing external command: Galish full command for ConfigStruct 'Configuration 5'

Executing external command: Galish full command for ConfigStruct 'Configuration 6'

Executing external command: Galish full command for ConfigStruct 'Configuration 7'

Executing external command: Galish full command for ConfigStruct 'Configuration 8'

Executing external command: Galish full command for ConfigStruct 'Configuration 9'

Executing external command: Galish full command for ConfigStruct 'Configuration 10'

Executing external command: Galish full command for ConfigStruct 'Configuration 11'

Executing external command: Galish full command for ConfigStruct 'Configuration 12'

Executing external command: Galish full command for ConfigStruct 'Configuration 13'

Total time (1 thread) = 1374 ms