complete. Not stable!

Author: ChippyPlus

main.kar

@@ -2,16 +2,15 @@ lit s1 9
 str s2 "main.mar"
 syscall
 
-push r2
 
-lit s1 12 // pause main.mar
-peek s2
+// Run main.mar
+mov r2 r1
+lit s1 12
+mov r1 s2
 syscall
 
-prints
 
-lit g1 5000
-sleep g1
+// Pause main.mar
 
 str s3 "I love dogs!"
 mov s3 f1
@@ -20,13 +19,17 @@ pop g1
 add g1 s3
 
 
+// Load "I love dogs!" into memory
+
 lit s1 11 // mem share
 mov r2 s2 // share VM
 mov r4 s4
 syscall
 
+// Share main.kar's memory with main.mar
 
-lit s1 13 // continue main.mar
-peek s2
+lit s1 13
+mov r1 s2
 syscall
 
+// Continue main.mar

main.mar

@@ -1,4 +1,2 @@
-lit g1 10
-printr g1
 lit f1 9
 call println

src/main/kotlin/Main.kt

@@ -6,6 +6,9 @@ import environment.reflection.VmTracked
 import environment.reflection.reflection
 import helpers.Config
 import internals.Vm
+import kotlinx.coroutines.DelicateCoroutinesApi
+import kotlinx.coroutines.ExperimentalCoroutinesApi
+import kotlinx.coroutines.newSingleThreadContext
 import kotlinx.coroutines.runBlocking
 import optimisations.VarRedundancy
 import java.io.File
@@ -18,7 +21,8 @@ val MEMORY_LIMIT = config?.memorySize ?: 256
 val taskManager = TaskManager()
 val init = Vm()
 
-fun main(args: Array<String>): Unit = runBlocking {
+@OptIn(ExperimentalCoroutinesApi::class, DelicateCoroutinesApi::class)
+fun main(args: Array<String>): Unit = runBlocking(newSingleThreadContext("Kotlin's main")) {
 	val tracked = VmTracked(init)
 	tracked.thread = Thread.currentThread()
 	reflection.vmTracker.add(tracked)
@@ -73,10 +77,7 @@ fun main(args: Array<String>): Unit = runBlocking {
 
 	taskManager.wait()
 
-
 }
 
 
-fun exitVM(): Nothing = exitProcess(0)
-
 

src/main/kotlin/engine/execution/Execute.kt

@@ -34,11 +34,15 @@ class Execute(val vm: Vm) {
 	suspend fun run(command: List<InstructData>) {
 		while (true) {
 
+//			println("${vm.pc}  | ${ reflection.vmTracker.groupBy(VmTracked::vm)[vm]!![0].id} -  ${vm.runtimeState}")
+
+
 			when (vm.runtimeState) {
 				RuntimeStates.RUNNING -> {/* pass */
+
 				}
 
-				RuntimeStates.PAUSED -> delay(1)
+				RuntimeStates.PAUSED -> continue
 				RuntimeStates.CANCELLED -> break
 			}
 

src/main/kotlin/environment/TaskManager.kt

@@ -6,19 +6,20 @@ import taskManager
 
 
 class TaskManager {
-	private val startTime = System.currentTimeMillis()
 	private val taskChannel = Channel<suspend () -> Unit>() // Channel for Unit-returning functions
-	private val taskScope = CoroutineScope(Dispatchers.Default + SupervisorJob())
+	private val taskScope = CoroutineScope(Dispatchers.IO + SupervisorJob())
 	private lateinit var taskManager: Job
 	private val activeTasks = mutableListOf<Job>()  // Keep track of active tasks
 
 
+	@OptIn(ExperimentalCoroutinesApi::class, DelicateCoroutinesApi::class)
 	fun addTask(block: suspend () -> Unit) {
 		taskScope.launch { taskChannel.send(block) }
-		if (!::taskManager.isInitialized) { //Start the task manager only once.
+		if (!::taskManager.isInitialized) {
 			taskManager = taskScope.launch {
 				for (task in taskChannel) {
-					val taskJob = launch { task() } // Launch each task concurrently
+					val taskJob =
+						launch(newSingleThreadContext("Kotlin's slaves \$${activeTasks.size + 1}")) { task() } // Launch each task concurrently
 					activeTasks.add(taskJob)
 				}
 				activeTasks.joinAll()
@@ -38,6 +39,7 @@ class TaskManager {
 }
 
 
+@OptIn(ExperimentalCoroutinesApi::class, DelicateCoroutinesApi::class)
 fun main() = runBlocking {
 
 	println("Main thread doing other work...")

src/main/kotlin/helpers/Config.kt

@@ -1,18 +1,24 @@
 package helpers
 
+import kotlinx.coroutines.*
 import kotlinx.serialization.json.Json
 import java.io.File
 
-class Config(f: File) {
+class Config(private val f: File) {
 	private var content: ConfigStructure? = null
 
 	init {
-		val contents = f.readText()
-		content = Json.decodeFromString<ConfigStructure>(contents)
+		runBlocking { init() }
 	}
 
 	val hertz = content?.hertz!!.toLong() / 2
 	val stackSize = content?.stackSize!!
 	val memorySize = content?.memorySize!!
 	val paths = content?.locations!!
+
+	@OptIn(ExperimentalCoroutinesApi::class, DelicateCoroutinesApi::class)
+	private suspend fun init() = CoroutineScope(Dispatchers.IO).launch(newSingleThreadContext("Kotlin's Config Init")) {
+		val contents = f.readText()
+		content = Json.decodeFromString<ConfigStructure>(contents)
+	}.join()
 }