concurrency implemented

Author: FalsePattern

README.MD

@@ -25,4 +25,4 @@ A standard-conforming Funge-98 interpreter.
 
 ### Additional goals
 - [ ] File IO
-- [ ] Concurrency
+- [x] Concurrency

src/main/java/com/falsepattern/jfunge/interpreter/ExecutionContext.java

@@ -11,6 +11,7 @@
 public interface ExecutionContext {
     InstructionPointer[] allIPs();
     InstructionPointer IP();
+    InstructionPointer cloneIP();
     FungeSpace fungeSpace();
     int dimensions();
     boolean stopped();

src/main/java/com/falsepattern/jfunge/interpreter/Interpreter.java

@@ -18,7 +18,7 @@ public class Interpreter implements ExecutionContext {
     @Getter
     private final FungeSpace fungeSpace = new FungeSpace(' ');
 
-    private final InstructionPointer IP = new InstructionPointer();
+    private final List<InstructionPointer> IPs = new ArrayList<>();
 
     private final InstructionManager baseInstructionManager = new InstructionManager();
 
@@ -36,6 +36,12 @@ public class Interpreter implements ExecutionContext {
 
     private Integer exitCode = null;
 
+    private InstructionPointer currentIP = null;
+
+    private InstructionPointer clone = null;
+
+    private int nextUUID = 0;
+
     public static int executeProgram(boolean trefunge, String[] args, byte[] program, long iterLimit, InputStream input, OutputStream output) {
         val interpreter = new Interpreter(trefunge, args, input, output);
         interpreter.fungeSpace().loadFileAt(0, 0, 0, program, trefunge);
@@ -60,21 +66,31 @@ public Interpreter(boolean trefunge, String[] args, InputStream input, OutputStr
         baseInstructionManager.loadInstructionSet(Funge98.INSTANCE);
         this.input = input;
         this.output = output;
+        val ip = new InstructionPointer();
+        ip.UUID = nextUUID++;
+        IPs.add(ip);
     }
 
     @Override
     public InstructionPointer[] allIPs() {
-        return new InstructionPointer[]{IP};
+        return IPs.toArray(new InstructionPointer[0]);
     }
 
     @Override
     public InstructionPointer IP() {
-        return IP;
+        return currentIP;
+    }
+
+    @Override
+    public InstructionPointer cloneIP() {
+        clone = currentIP.deepCopy();
+        clone.UUID = nextUUID++;
+        return clone;
     }
 
     @Override
     public boolean stopped() {
-        if (dead()) {
+        if (IPs.size() == 0) {
             exitCode = 0;
         }
         return exitCode != null;
@@ -90,10 +106,6 @@ public int exitCode() {
         return exitCode == null ? 0 : exitCode;
     }
 
-    public boolean dead() {
-        return IP.isDead();
-    }
-
     @Override
     public void interpret(int opcode) {
         if (opcode == '"') {
@@ -165,8 +177,21 @@ public int paradigm() {
     }
 
     public void tick() {
-        for (InstructionPointer ip : allIPs()) {
-            interpret(fungeSpace().get(ip.position));
+        currentIP = null;
+        for (int i = 0; i < IPs.size(); i++) {
+            currentIP = IPs.get(i);
+            if (IP().isDead()) {
+                IPs.remove(i);
+                i--;
+                continue;
+            }
+            interpret(fungeSpace().get(IP().position));
+            if (clone != null) {
+                IPs.add(i++, clone);
+                clone = null;
+            }
+        }
+        for (val ip: IPs) {
             step(ip);
         }
     }

src/main/java/com/falsepattern/jfunge/interpreter/instructions/Funge98.java

@@ -402,7 +402,7 @@ public static void sysInfo(ExecutionContext ctx) {
         //9 teamnumber
         s.push(0);
         //8 uuid
-        s.push(0);
+        s.push(ctx.IP().UUID);
         //7 dimensions
         s.push(ctx.dimensions());
         //6 separator
@@ -416,7 +416,7 @@ public static void sysInfo(ExecutionContext ctx) {
         //2 bpc
         s.push(4);
         //1 flags
-        s.push(0);
+        s.push(0b00000001);
         if (n > 0) {
             int curr = s.pick(n - 1);
             for (int i = s.size(); i >= tossSize; i--) {
@@ -432,6 +432,12 @@ public static void quit(ExecutionContext ctx) {
         ctx.stop(q);
     }
 
+    @Instr('t')
+    public static void split(ExecutionContext ctx) {
+        val clone = ctx.cloneIP();
+        clone.delta.mul(-1);
+    }
+
     @Override
     public void load(ObjIntConsumer<Instruction> instructionSet) {
         InstructionSet.super.load(instructionSet);

src/main/java/com/falsepattern/jfunge/interpreter/instructions/InstructionManager.java

@@ -60,6 +60,6 @@ public Instruction fetch(int c) {
 
     @Override
     public InstructionManager deepCopy() {
-        return null;
+        return new InstructionManager(this);
     }
 }

src/main/java/com/falsepattern/jfunge/ip/InstructionPointer.java

@@ -17,6 +17,7 @@ public class InstructionPointer implements Copiable<InstructionPointer> {
     @Getter
     private boolean dead = false;
     public boolean stringMode = false;
+    public int UUID;
 
     public InstructionPointer() {
         position = new Vector3i();
@@ -36,6 +37,7 @@ private InstructionPointer(InstructionPointer original) {
         stringMode = original.stringMode;
         instructionManager = original.instructionManager.deepCopy();
         customStorage = new TObjectIntHashMap<>(original.customStorage);
+        UUID = 0;
     }
 
     public void die() {