Fixed rate timer based TickEvent

Author: Avanatiker

common/src/main/kotlin/com/lambda/event/EventFlow.kt

@@ -19,12 +19,14 @@ package com.lambda.event
 
 import com.lambda.context.SafeContext
 import com.lambda.event.callback.ICancellable
+import com.lambda.event.events.ClientEvent
 import com.lambda.event.listener.Listener
 import com.lambda.threading.runConcurrent
 import com.lambda.threading.runSafe
 import kotlinx.coroutines.*
 import kotlinx.coroutines.channels.BufferOverflow
 import kotlinx.coroutines.flow.*
+import kotlin.concurrent.fixedRateTimer
 
 
 /**
@@ -76,6 +78,17 @@ object EventFlow {
      */
     val concurrentListeners = Subscriber()
 
+    init {
+        fixedRateTimer(
+            daemon = true,
+            name = "Scheduler-Lambda-Tick",
+            initialDelay = 50L,
+            period = 50L
+        ) {
+            ClientEvent.FixedTick().post()
+        }
+    }
+
     fun Any.unsubscribe() {
         syncListeners.unsubscribe(this)
         concurrentListeners.unsubscribe(this)

common/src/main/kotlin/com/lambda/event/events/ClientEvent.kt

@@ -44,4 +44,6 @@ sealed class ClientEvent {
      * Triggered before playing a sound
      */
     data class Sound(val sound: SoundInstance) : ICancellable by Cancellable()
+
+    class FixedTick : Event
 }

common/src/main/kotlin/com/lambda/event/listener/SafeListener.kt

@@ -22,6 +22,7 @@ import com.lambda.event.Event
 import com.lambda.event.EventFlow
 import com.lambda.event.Muteable
 import com.lambda.threading.runConcurrent
+import com.lambda.threading.runGameScheduled
 import com.lambda.threading.runSafe
 import com.lambda.util.Pointer
 import com.lambda.util.selfReference
@@ -121,7 +122,7 @@ class SafeListener<T : Event>(
             noinline function: SafeContext.(T) -> Unit = {},
         ): SafeListener<T> {
             val listener = SafeListener<T>(priority, this, alwaysListen) { event ->
-                function(event)
+                runGameScheduled { function(event) }
             }
 
             EventFlow.syncListeners.subscribe(listener)

common/src/main/kotlin/com/lambda/module/modules/debug/TimerTest.kt

@@ -0,0 +1,48 @@
+/*
+ * Copyright 2025 Lambda
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program.  If not, see <http://www.gnu.org/licenses/>.
+ */
+
+package com.lambda.module.modules.debug
+
+import com.lambda.event.events.ClientEvent
+import com.lambda.event.listener.SafeListener.Companion.listen
+import com.lambda.event.listener.SafeListener.Companion.listenConcurrently
+import com.lambda.module.Module
+import com.lambda.module.tag.ModuleTag
+import com.lambda.util.Communication.info
+import com.lambda.util.KeyCode
+import net.minecraft.block.Blocks
+import net.minecraft.util.math.BlockPos
+import java.awt.Color
+
+object TimerTest : Module(
+    name = "TimerTest",
+    defaultTags = setOf(ModuleTag.DEBUG)
+) {
+    private var last = 0L
+
+    init {
+        listen<ClientEvent.FixedTick> {
+            val now = System.currentTimeMillis()
+            info("${now - last} - Fixed Tick on game thread")
+            last = now
+        }
+
+        listenConcurrently<ClientEvent.FixedTick> {
+//            info("${System.currentTimeMillis()} - Fixed Tick Concurrently (but not on mc game thread)")
+        }
+    }
+}