首頁猿問有限制的運(yùn)行配置

有限制的運(yùn)行配置

Java

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

我對(duì)如何繼續(xù)我的代碼有疑問。我的項(xiàng)目是一個(gè)在后臺(tái)一個(gè)一個(gè)地運(yùn)行配置的工具。我想為運(yùn)行配置的數(shù)量添加一個(gè)限制。例如，如果我有 13 個(gè)配置，我想每次運(yùn)行 5 個(gè)配置，所以順序是：- Running 5 configurations- All 5 configurations done running- Running 5 configurations- All 5 configurations done running- Running 3 configurations- All 3 configurations done running現(xiàn)在的代碼，工作如下：public void runConfigurations(List<ConfigStruct> configurations) { for (ConfigStruct configuration : configurations) { try { configuration.run(); } catch (ConfigurationException e) { continue; } }}現(xiàn)在，它一個(gè)一個(gè)地運(yùn)行每個(gè)配置。該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;起初，我雖然可以不在后臺(tái)每 5 個(gè)配置運(yùn)行最后一個(gè)配置，但它有問題。我不能不在后臺(tái)執(zhí)行每 5 個(gè)配置的最后一個(gè)配置，因?yàn)榈谝粋€(gè)配置可能最后完成。我該如何解決這個(gè)問題？編輯：當(dāng)我打印配置時(shí)，它看起來如下：[com.configStructs@3f15dbec, com.configStructs@31d2327e]此外，這configurations是一個(gè)列表configStructs。

查看完整描述

2 回答

神不在的星期二

TA貢獻(xiàn)1963條經(jīng)驗(yàn) 獲得超6個(gè)贊

抱歉vesii如果我不完全理解甚至誤解你的問題，但你的英語不是很好，即使在你發(fā)表評(píng)論后我也有問題，看看使用多線程的問題是什么。

無論如何，我建議你讓你的ConfigStruct類實(shí)現(xiàn)Runnable接口，這很容易，因?yàn)樗呀?jīng)有一個(gè)run()方法。您只需要擺脫拋出已檢查的異常，因此我進(jìn)一步建議創(chuàng)建ConfigurationException一個(gè)RuntimeException您不必在方法簽名中聲明的異常。

不幸的是，您沒有提供完整的MCVE，只有代碼片段。所以我必須彌補(bǔ)其余部分才能編譯和運(yùn)行您的代碼。我只是添加了一些簡(jiǎn)單的助手/虛擬類。我的解決方案如下所示：

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;

}

如您所見，命令執(zhí)行器在將內(nèi)容打印到控制臺(tái)后等待 100 毫秒。如果您希望程序運(yùn)行得更慢或什至隨機(jī)化以模擬需要不同時(shí)間完成的命令，您也可以將其更改為 1000 毫秒。

現(xiàn)在我們需要一個(gè)小的驅(qū)動(dòng)程序應(yīng)用程序，我們可以在其中生成配置并運(yùn)行它們。解決你從不同時(shí)運(yùn)行超過 5 個(gè)線程的問題的關(guān)鍵是通過創(chuàng)建一個(gè)固定的線程池Executors.newFixedThreadPool(5)。其余的應(yīng)該很容易理解。

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");

}

控制臺(tái)日志將如下所示：

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