games/RedMew
games/RedMew
1
0
Fork 0
mirror of https://github.com/Refactorio/RedMew.git synced 2024-12-12 10:04:40 +02:00
Code Issues Releases Activity

Thread logarithmic actions per tick increase proposal

Browse Source
This commit is contained in:
Valansch 2017-10-25 13:00:45 +02:00
parent e2dacdff58
commit 66da00f1fb
2 changed files with 12 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
locale/gen_combined/dagobah_swamp.lua
View File

@ -364,7 +364,6 @@ function run_swamp_entities(params)
end end
function run_combined_module(event) function run_combined_module(event)
Thread.set_actions_per_tick(10)
-- Generate Rivers -- Generate Rivers
if not global.perlin_noise_seed then global.perlin_noise_seed = math.random(1000,1000000) end if not global.perlin_noise_seed then global.perlin_noise_seed = math.random(1000,1000000) end

18
locale/utils/Thread.lua
View File

@ -18,11 +18,11 @@ end
global.callbacks = {} global.callbacks = {}
global.next_async_callback_time = -1 global.next_async_callback_time = -1
global.actions_per_tick = 1 global.actions_queue_n = 0
local function on_tick() local function on_tick()
for action = 1, global.actions_per_tick do for action = 1, get_actions_per_tick() do
if global.actions_queue[1] then if global.actions_queue[1] then
global.actions_queue_n = global.actions_queue_n - 1
local callback = global.actions_queue[1] local callback = global.actions_queue[1]
pcall(_G[callback.action], callback.params) pcall(_G[callback.action], callback.params)
table.remove(global.actions_queue, 1) table.remove(global.actions_queue, 1)
@ -43,8 +43,14 @@ local function on_tick()
end end
end end
function Thread.set_actions_per_tick(count) function get_actions_per_tick(count)
global.actions_per_tick = count --Assert actions_queue_n > -1
local apt = math.floor(math.log10(global.actions_queue_n + 1))
if apt < 1 then
return 1
else
return apt
end
end end
function Thread.set_timeout_in_ticks(ticks, callback, params) function Thread.set_timeout_in_ticks(ticks, callback, params)
@ -63,7 +69,7 @@ end
global.actions_queue = {} global.actions_queue = {}
function Thread.queue_action(action, params) function Thread.queue_action(action, params)
global.actions_queue_n = global.actions_queue_n + 1
table.insert(global.actions_queue, {action = action, params = params}) table.insert(global.actions_queue, {action = action, params = params})
end end