curioustorvald/Terrarum
1
0
Fork 0
mirror of https://github.com/curioustorvald/Terrarum.git synced 2026-06-19 23:14:05 +09:00
Code Issues Packages Projects Releases Wiki Activity

failed attempt at multithreading

Browse Source
This commit is contained in:
minjaesong
2017-07-08 22:34:45 +09:00
parent f71905b880
commit b57b0cb04c
2 changed files with 42 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

45
src/net/torvald/terrarum/Ingame.kt
View File

@@ -136,6 +136,11 @@ class Ingame(val batch: SpriteBatch) : Screen {
private set
private lateinit var ingameUpdateThread: ThreadIngameUpdate
private lateinit var updateThreadWrapper: Thread
//private val ingameDrawThread: ThreadIngameDraw // draw must be on the main thread
//////////////
// GDX code //
//////////////
@@ -313,16 +318,31 @@ class Ingame(val batch: SpriteBatch) : Screen {
ingameUpdateThread = ThreadIngameUpdate(this)
updateThreadWrapper = Thread(ingameUpdateThread, "Terrarum UpdateThread")
LightmapRenderer.fireRecalculateEvent()
}// END enter
private var updateDeltaCounter = 0.0
private val updateRate = 1.0 / Terrarum.TARGET_INTERNAL_FPS
protected var updateDeltaCounter = 0.0
protected val updateRate = 1.0 / Terrarum.TARGET_INTERNAL_FPS
private var firstTimeRun = true
///////////////
// prod code //
///////////////
private class ThreadIngameUpdate(val ingame: Ingame): Runnable {
override fun run() {
while (ingame.updateDeltaCounter >= ingame.updateRate) {
ingame.updateGame(Gdx.graphics.deltaTime)
ingame.updateDeltaCounter -= ingame.updateRate
}
}
}
override fun render(delta: Float) {
Gdx.graphics.setTitle(GAME_NAME +
" — F: ${Gdx.graphics.framesPerSecond} (${Terrarum.TARGET_INTERNAL_FPS})" +
@@ -335,9 +355,22 @@ class Ingame(val batch: SpriteBatch) : Screen {
/** UPDATE CODE GOES HERE */
updateDeltaCounter += delta
while (updateDeltaCounter >= updateRate) {
updateGame(delta)
updateDeltaCounter -= updateRate
if (false && Terrarum.getConfigBoolean("multithread")) { // NO MULTITHREADING: camera don't like concurrent modification (jittery actor movements)
if (firstTimeRun || updateThreadWrapper.state == Thread.State.TERMINATED) {
updateThreadWrapper = Thread(ingameUpdateThread, "Terrarum UpdateThread")
updateThreadWrapper.start()
if (firstTimeRun) firstTimeRun = false
}
// else, NOP;
}
else {
while (updateDeltaCounter >= updateRate) {
updateGame(delta)
updateDeltaCounter -= updateRate
}
}
@@ -346,7 +379,7 @@ class Ingame(val batch: SpriteBatch) : Screen {
renderGame(batch)
}
private fun updateGame(delta: Float) {
protected fun updateGame(delta: Float) {
particlesActive = 0