src/de/steamwar/bungeecore/Subserver.java

@@ -72,6 +72,7 @@ public class Subserver implements Runnable {
     private final PrintWriter writer;
     private final ServerInfo server;
     private final Servertype type;
+    private final Thread thread;
     private boolean started;
 
     private final List<ProxiedPlayer> cachedPlayers = new LinkedList<>();
@@ -102,7 +103,8 @@ public class Subserver implements Runnable {
                 serverName, address, "SteamWar.de - Subserver", false);
         this.writer = new PrintWriter(process.getOutputStream(), true);
 
-        ProxyServer.getInstance().getScheduler().runAsync(Persistent.getInstance(), this);
+        this.thread = new Thread(this, "Subserver " + serverName);
+        this.thread.start();
     }
 
     public ServerInfo getServer(){
@@ -133,6 +135,7 @@ public class Subserver implements Runnable {
         try {
             if(!process.waitFor(1, TimeUnit.MINUTES))
                 process.destroy();
+            thread.join();
         }catch(InterruptedException e){
             logger.log(Level.SEVERE, "Subserver stop interrupted!", e);
             Thread.currentThread().interrupt();
@@ -144,6 +147,7 @@ public class Subserver implements Runnable {
             if(!process.waitFor(5, TimeUnit.MINUTES) && server.getPlayers().isEmpty()){
                 process.destroy();
             }
+            thread.join();
         }catch(InterruptedException e){
             logger.log(Level.SEVERE, "Subserver stop interrupted!", e);
             Thread.currentThread().interrupt();