package at.hannibal2.skyhanni.utils import at.hannibal2.skyhanni.test.command.ErrorManager import at.hannibal2.skyhanni.utils.CollectionUtils.drainTo import java.util.concurrent.ConcurrentLinkedQueue import kotlin.time.Duration object DelayedRun { private val tasks = mutableListOf Any, SimpleTimeMark>>() private val futureTasks = ConcurrentLinkedQueue Any, SimpleTimeMark>>() fun runDelayed(duration: Duration, run: () -> Unit) { futureTasks.add(Pair(run, SimpleTimeMark.now() + duration)) } /** Runs in the next full Tick so the delay is between 50ms to 100ms**/ fun runNextTick(run: () -> Unit) { futureTasks.add(Pair(run, SimpleTimeMark.farPast())) } fun checkRuns() { tasks.removeIf { (runnable, time) -> val inPast = time.isInPast() if (inPast) { try { runnable() } catch (e: Exception) { ErrorManager.logErrorWithData(e, "DelayedRun task crashed while executing") } } inPast } futureTasks.drainTo(tasks) } }