Better fluid updater

[cavedroid.git] / core / src / ru / deadsoftware / cavedroid / game / GameProc.java

diff --git a/core/src/ru/deadsoftware/cavedroid/game/GameProc.java b/core/src/ru/deadsoftware/cavedroid/game/GameProc.java
index cd957a0842583ebc6f8fc5ec87bc353a60a6abfa..53b2b9060ed6eca4fd65e0aa73d4c4380837d47e 100644 (file)
--- a/core/src/ru/deadsoftware/cavedroid/game/GameProc.java
+++ b/core/src/ru/deadsoftware/cavedroid/game/GameProc.java
@@ -2,6 +2,7 @@ package ru.deadsoftware.cavedroid.game;
 
 import com.badlogic.gdx.Gdx;
 import com.badlogic.gdx.Input;
+import com.badlogic.gdx.utils.Disposable;
 import com.badlogic.gdx.utils.TimeUtils;
 import ru.deadsoftware.cavedroid.CaveGame;
 import ru.deadsoftware.cavedroid.GameScreen;
@@ -17,11 +18,15 @@ import ru.deadsoftware.cavedroid.misc.Assets;
 import java.io.Serializable;
 import java.util.ArrayList;
 
-public class GameProc implements Serializable {
+public class GameProc implements Serializable, Disposable {
+
+    private static final int FLUID_UPDATE_INTERVAL_MS = 100;
 
     static boolean DO_UPD = false;
     static int UPD_X = -1, UPD_Y = -1;
 
+    private transient Thread fluidThread;
+
     public transient GameWorld world;
     public transient GameRenderer renderer;
     public transient GamePhysics physics;
@@ -30,6 +35,7 @@ public class GameProc implements Serializable {
     public ArrayList<Mob> mobs;
     public ArrayList<Drop> drops;
 
+    private long fluidLastUpdateTimestamp = 0;
 
     public boolean isTouchDown, isKeyDown;
     public int ctrlMode, touchDownX, touchDownY, touchDownBtn, keyDownCode;
@@ -43,8 +49,8 @@ public class GameProc implements Serializable {
         world = new GameWorld();
         world.generate(1024, 256);
         player = new Player(gameMode);
-        drops = new ArrayList<Drop>();
-        mobs = new ArrayList<Mob>();
+        drops = new ArrayList<>();
+        mobs = new ArrayList<>();
         for (int i = 0; i < 16; i++) {
             mobs.add(new Pig(i * 256, 196 * 16));
         }
@@ -59,16 +65,24 @@ public class GameProc implements Serializable {
         }
         maxCreativeScroll = GameItems.getItemsSize() / 8;
 
-        new Thread(new Runnable() {
-            @Override
-            public void run() {
-                while (true) fluidUpdater();
-            }
-        }).start();
+        createFluidThread();
+
+        fluidThread.start();
 
         GameSaver.save(this);
     }
 
+    private void createFluidThread() {
+        fluidThread = new Thread(() -> {
+            while (!fluidThread.isInterrupted()) {
+                if (System.currentTimeMillis() - fluidLastUpdateTimestamp > FLUID_UPDATE_INTERVAL_MS) {
+                    fluidUpdater();
+                    fluidLastUpdateTimestamp = System.currentTimeMillis();
+                }
+            }
+        });
+    }
+
     public void resetRenderer() {
         if (CaveGame.TOUCH) {
             renderer = new GameRenderer(320,
@@ -347,7 +361,6 @@ public class GameProc implements Serializable {
             } else if (GameItems.isWater(world.getForeMap(x, y + 1))) {
                 world.setForeMap(x, y + 1, 1);
             }
-            return;
         }
     }
 
@@ -384,9 +397,11 @@ public class GameProc implements Serializable {
     }
 
     private void fluidUpdater() {
+        int midScreen = (int) (renderer.getCamX() + renderer.getWidth() / 2) / 16;
         for (int y = 0; y < world.getHeight(); y++) {
-            for (int x = (int) renderer.getCamX() / 16 - 1; x < (int) (renderer.getCamX() + renderer.getWidth()) / 16 + 1; x++) {
-                updateFluids(x, y);
+            for (int x = 0; x < (int) (renderer.getWidth() / 2) / 16 + 1; x++) {
+                updateFluids(midScreen + x, y);
+                updateFluids(midScreen - x, y);
             }
         }
     }
@@ -397,16 +412,16 @@ public class GameProc implements Serializable {
                 if (!bg) world.placeToForeground(x, y, GameItems.getBlockIdByItemId(id));
                 else world.placeToBackground(x, y, GameItems.getBlockIdByItemId(id));
             } else {
-                    switch (id) {
-                        case 65:
-                            world.placeToForeground(x, y, 8);
-                            player.inv[player.invSlot] = 64;
-                            break;
-                        case 66:
-                            world.placeToForeground(x, y, 9);
-                            player.inv[player.invSlot] = 64;
-                            break;
-                    }
+                switch (id) {
+                    case 65:
+                        world.placeToForeground(x, y, 8);
+                        player.inv[player.invSlot] = 64;
+                        break;
+                    case 66:
+                        world.placeToForeground(x, y, 9);
+                        player.inv[player.invSlot] = 64;
+                        break;
+                }
             }
         }
     }
@@ -455,12 +470,21 @@ public class GameProc implements Serializable {
                 useItem(curX, curY, player.inv[player.invSlot], true);
                 isTouchDown = false;
             } else if (touchDownY < Assets.invBar.getRegionHeight() &&
-                    touchDownX > renderer.getWidth() / 2 - Assets.invBar.getRegionWidth() / 2 &&
-                    touchDownX < renderer.getWidth() / 2 + Assets.invBar.getRegionWidth() / 2) {
+                    touchDownX > renderer.getWidth() / 2 - (float) Assets.invBar.getRegionWidth() / 2 &&
+                    touchDownX < renderer.getWidth() / 2 + (float) Assets.invBar.getRegionWidth() / 2) {
                 CaveGame.STATE = AppState.GAME_CREATIVE_INV;
                 isTouchDown = false;
             }
         }
+
+        if (fluidThread == null || !fluidThread.isAlive()) {
+            createFluidThread();
+            fluidThread.start();
+        }
     }
 
+    @Override
+    public void dispose() {
+        fluidThread.interrupt();
+    }
 }