Java多線程：我如何啓動執行線程的外部Java程序？

Question

目前，我試圖編寫一個程序，它應該多次執行一個獨立的Java程序，但使用不同的參數。這個執行的Java程序調用一個線程類。在這個類中，建立到（遊戲）服務器的連接。一旦連接，線程將發送一個命令，每10毫秒轉換一次連接的播放器。我對這個2的「解決方案」：

最簡單的（工作）之一：

public class GeneralAgentTest { 

public static void main(String [] args){ 

    Thread thread = new Thread(new HexagonRunner("127.0.0.1",6000,"UnitedTestors",-30,-15)); 
    thread.start(); 
} 
} 

這是正常工作，但實際上不是我的目標。我需要啓動幾個這樣的線程（新線程（新的HexagonRunner（「127.0.0.1」，6000，「UnitedTestors」， - 30，-15））;），並且每個線程必須由一個獨立的進程來處理。

爲此，我使用ProcessBuilder編寫了一些代碼。這是在一個班級內。

二不能正常工作之一：

public void execute(Class class1, int a, String str, String team, String x, 
     String y) { 

    ProcessBuilder builder; 
    String javaHome = System.getProperty("java.home"); 
    String javaBin = javaHome + File.separator + "bin" + File.separator 
      + "java"; 
    String classpath = System.getProperty("java.class.path"); 
    String className = class1.getCanonicalName(); 

    builder = new ProcessBuilder(javaBin, "-cp", classpath, 
      className, ip, port, team, str, x, y); 

    try { 
     process[a] = builder.start(); 
    } catch (Exception e) { 
     e.printStackTrace(); 
     System.out.println("failed"); 
    } 

public void loadPlayers() { 
    process = new Process[4]; 
    for (int i = 0; i < 4; i++) { 
     try { 
      execute(processes.StartProcesses.class, i, 
        playerCombo[i].getSelectedItem().toString(), 
        playerTeam[i].getText(), playerStartX[i].getText(), 
        playerStartY[i].getText()); 

     } catch (Exception e) { 
      System.out.println("Failed to create processes for players"); 
      e.printStackTrace(); 
     } 
    } 
} 

這些都是我寫的功能，執行誰是/是啓動線程（或多個）類（ES）。 下面的類執行：

public class StartProcesses{ 

public static void main(String[] args) { 

     Thread t = null; 
     t = new Thread(new HexagonRunner("127.0.0.1",6000,"UnitedTestors",-30,-15)); 
     t.start(); 
      JOptionPane.showMessageDialog(null, "should've started"); 
} 
} 

在我的第二次嘗試，這是給予StartProcesses類的參數包含像IP-不會忽略，Portnumbers，Playerpositons和東西像這樣的一些信息。無論如何，我試圖用「硬」信息來執行這個類，只是爲了確保它在我的第一個代碼部分中工作。

兩次嘗試都正確建立了到服務器的連接，但是在第一個連接中線程仍在工作。在我的第二次嘗試中，連接建立後線程似乎已經死亡。該過程仍然存在，因爲與服務器的連接仍然存在。

這是一段代碼，但我想告訴的是，線程在手動執行時正常工作，但如果我嘗試使用ProcessBuilder自動啓動類，它將無法正常工作。

我真的很希望你們能明白我在說什麼。希望有人對我有一個工作解決方案。

乾杯。

編輯：添加代碼爲HexagonRunner：

public class HexagonRunner extends GeneralAgent { 

// Bunch of Methods 
// Important Method: 

    @Override 
protected void simulationCycle() { 

    turnAgent(40); 


} 
} 

的simulationCycle（）方法，是將要經過一遍又一遍的方法。 由於類HexagonRunner從類GeneralAgent繼承，我要在這裏發佈這一類的相關的東西，以及：

public class GeneralAgent implements Runnable, UdpListener{ 

// Attributes, getters, setters, methods.. 

@Override 
public final void run() { 
    // giving the worker threads the signal to start 
    mServerConnection.start(); 
    mParser.start(); 

    // waiting for the first information to be parsed, so that the 
    // simulation loop can run 
    try{ 
     System.out.println("GeneralAgent-Run: waiting for latch"); 
     mLogger.info("Run method: waiting for CountDownLatch"); 
     mFirstDone.await(); 
    } 
    catch(InterruptedException e){ 
     System.out.println("GeneralAgent-Run: InterruptedException"); 
     mLogger.info("Run method error: " + e.getMessage()); 
    } 
    mLogger.info("Run method: CountDownLatch now 0, continue"); 
    // setting the initial position 
    moveToPostion(mXStartCoord, mYStartCoord); 

    // the simulation loop 

    while (true){ 
     simulationCycle(); 

     // Shutdown if the game is over 
     if (mGameworld.getTime() >= 6000){ // later 6000+ 
      System.out.println("Yeah, 50 runs completed -> Shutdown"); 
      mLogger.info("General Agent - Time > 50, programm should terminate"); 
      shutdown(); 
      break; 
     } 
     // waiting for the threads to signal that they are 
     // ready (e.g. have new server information) 
     // for another round of the simulation loop 
     mPhaser.arriveAndAwaitAdvance(); 
    } 
} 

我希望事情變得更清晰了。我仍然不知道我的代碼在哪裏失敗。

Answer 1

通過使用Executors，您可以更簡單地構建一些事情。它是Java 1.5中引入的併發包的一部分。它主要的工作原理如下：

// create a pool with 10 threads 
ExecutorService executorService = Executors.newFixedThreadPool(10); 
//loop as long as you need to detach your threads 
for (int i = 0; i < 4; i++) { 
    // this actually contains the thread bit, will be executed in parallel 
    executorService.execute(new Runnable() { 
     public void run() { 
      // this is where your code is 
      new HexagonRunner("127.0.0.1",6000,"UnitedTestors",-30,-15) 
     } 
    }); 
} 
// clean up when you're done to prevent leaks 
executorService.shutdown(); 

就是這樣，多簡單，你不需要通過的ProcessBuilder，這是慢了很多產卵不同的JVM。