Integrated thread implementation / Crash fix

core/src/io/anuke/mindustry/Vars.java

@@ -166,7 +166,7 @@ public class Vars{
             });
         }
 
-        threads = new ThreadHandler(Platform.instance.getThreadProvider());
+        threads = new ThreadHandler();
 
         mobile = Gdx.app.getType() == ApplicationType.Android || Gdx.app.getType() == ApplicationType.iOS || testMobile;
         ios = Gdx.app.getType() == ApplicationType.iOS;

core/src/io/anuke/mindustry/core/ContentLoader.java

@@ -210,7 +210,7 @@ public class ContentLoader{
         if(id < 0) id += 256;
 
         if(temporaryMapper != null && temporaryMapper[type.ordinal()] != null && temporaryMapper[type.ordinal()].length != 0){
-            if(temporaryMapper[type.ordinal()][id] == null){
+            if(temporaryMapper[type.ordinal()].length <= id || temporaryMapper[type.ordinal()][id] == null){
                 return getByID(type, 0); //default value is always ID 0
             }
             return (T)temporaryMapper[type.ordinal()][id];

core/src/io/anuke/mindustry/core/Platform.java

@@ -2,7 +2,6 @@ package io.anuke.mindustry.core;
 
 import com.badlogic.gdx.files.FileHandle;
 import com.badlogic.gdx.utils.Base64Coder;
-import io.anuke.mindustry.core.ThreadHandler.ThreadProvider;
 import io.anuke.ucore.core.Settings;
 import io.anuke.ucore.function.Consumer;
 import io.anuke.ucore.scene.ui.TextField;
@@ -67,17 +66,6 @@ public abstract class Platform {
      * @param filetype File extension to filter
      */
     public void showFileChooser(String text, String content, Consumer<FileHandle> cons, boolean open, String filetype){}
-    /**Use the default thread provider from the kryonet module for this.*/
-    public ThreadProvider getThreadProvider(){
-        return new ThreadProvider() {
-            @Override public boolean isOnThread() {return true;}
-            @Override public void sleep(long ms) {}
-            @Override public void start(Runnable run) {}
-            @Override public void stop() {}
-            @Override public void notify(Object object) {}
-            @Override public void wait(Object object) {}
-        };
-    }
 
     /**Forces the app into landscape mode. Currently Android only.*/
     public void beginForceLandscape(){}

core/src/io/anuke/mindustry/core/ThreadHandler.java

@@ -6,13 +6,15 @@ import com.badlogic.gdx.utils.TimeUtils;
 import io.anuke.ucore.core.Settings;
 import io.anuke.ucore.core.Timers;
 import io.anuke.ucore.util.Log;
+import io.anuke.ucore.util.Threads;
+import io.anuke.ucore.util.Threads.ThreadInfoProvider;
 
 import static io.anuke.mindustry.Vars.control;
 import static io.anuke.mindustry.Vars.logic;
 
-public class ThreadHandler{
+public class ThreadHandler implements ThreadInfoProvider{
     private final Queue<Runnable> toRun = new Queue<>();
-    private final ThreadProvider impl;
+    private Thread thread, graphicsThread;
     private final Object updateLock = new Object();
     private float delta = 1f;
     private float smoothDelta = 1f;
@@ -22,11 +24,12 @@ public class ThreadHandler{
     private boolean rendered = true;
     private long lastFrameTime;
 
-    public ThreadHandler(ThreadProvider impl){
-        this.impl = impl;
+    public ThreadHandler(){
+        Threads.setThreadInfoProvider(this);
+        graphicsThread = Thread.currentThread();
 
         Timers.setDeltaProvider(() -> {
-            float result = impl.isOnThread() ? delta : Gdx.graphics.getDeltaTime() * 60f;
+            float result = isOnThread() ? delta : Gdx.graphics.getDeltaTime() * 60f;
             return Math.min(Float.isNaN(result) ? 1f : result, 15f);
         });
     }
@@ -86,7 +89,7 @@ public class ThreadHandler{
             long elapsed = TimeUtils.timeSinceMillis(lastFrameTime);
             if(elapsed < target){
                 try{
-                    impl.sleep(target - elapsed);
+                    Thread.sleep(target - elapsed);
                 }catch(InterruptedException e){
                     e.printStackTrace();
                 }
@@ -99,7 +102,7 @@ public class ThreadHandler{
 
         synchronized(updateLock){
             rendered = true;
-            impl.notify(updateLock);
+            Threads.notify(updateLock);
         }
     }
 
@@ -111,12 +114,25 @@ public class ThreadHandler{
         if(enabled){
             logic.doUpdate = false;
             Timers.runTask(2f, () -> {
-                impl.start(this::runLogic);
+                if(thread != null){
+                    thread.interrupt();
+                    thread = null;
+                }
+
+                thread = new Thread(this::runLogic);
+                thread.setDaemon(true);
+                thread.setName("Update Thread");
+                thread.start();
+                Log.info("Starting logic thread.");
+
                 this.enabled = true;
             });
         }else{
             this.enabled = false;
-            impl.stop();
+            if(thread != null){
+                thread.interrupt();
+                thread = null;
+            }
             Timers.runTask(2f, () -> {
                 logic.doUpdate = true;
             });
@@ -128,7 +144,17 @@ public class ThreadHandler{
     }
 
     public boolean isOnThread(){
-        return impl.isOnThread();
+        return Thread.currentThread() == thread;
+    }
+
+    @Override
+    public boolean isOnLogicThread() {
+        return !enabled || Thread.currentThread() == thread;
+    }
+
+    @Override
+    public boolean isOnGraphicsThread() {
+        return !enabled || Thread.currentThread() == graphicsThread;
     }
 
     private void runLogic(){
@@ -157,12 +183,12 @@ public class ThreadHandler{
                 long target = (long) ((1000) / 60f);
 
                 if(elapsed < target){
-                    impl.sleep(target - elapsed);
+                    Thread.sleep(target - elapsed);
                 }
 
                 synchronized(updateLock){
                     while(!rendered){
-                        impl.wait(updateLock);
+                        Threads.wait(updateLock);
                     }
                     rendered = false;
                 }
@@ -184,18 +210,4 @@ public class ThreadHandler{
             control.setError(ex);
         }
     }
-
-    public interface ThreadProvider{
-        boolean isOnThread();
-
-        void sleep(long ms) throws InterruptedException;
-
-        void start(Runnable run);
-
-        void stop();
-
-        void wait(Object object) throws InterruptedException;
-
-        void notify(Object object);
-    }
 }

core/src/io/anuke/mindustry/io/SaveIO.java

@@ -165,6 +165,7 @@ public class SaveIO{
 
             stream.close();
         }catch(Exception e){
+            content.setTemporaryMapper(null);
             throw new RuntimeException(e);
         }
     }