首頁猿問有限制的運行配置

有限制的運行配置

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