-
Notifications
You must be signed in to change notification settings - Fork 0
/
runtime_looping_frame.go
99 lines (80 loc) · 1.89 KB
/
runtime_looping_frame.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
package core
import (
"git.golaxy.org/core/runtime"
"time"
)
func (rt *RuntimeBehavior) loopingWithFrame() {
gcTicker := time.NewTicker(rt.opts.GCInterval)
defer gcTicker.Stop()
frame := runtime.UnsafeFrame(rt.opts.Frame)
go rt.makeFrameTasks(frame.GetCurFrames()+1, frame.GetTotalFrames(), frame.GetTargetFPS())
loop:
for rt.frameLoopBegin(); ; {
select {
case task, ok := <-rt.processQueue:
if !ok {
break loop
}
rt.runTask(task)
case <-gcTicker.C:
rt.runGC()
case <-rt.ctx.Done():
break loop
}
}
close(rt.processQueue)
loopEnding:
for {
select {
case task, ok := <-rt.processQueue:
if !ok {
break loopEnding
}
rt.runTask(task)
default:
break loopEnding
}
}
rt.frameLoopEnd()
}
func (rt *RuntimeBehavior) makeFrameTasks(curFrames, totalFrames uint64, targetFPS float32) {
updateTicker := time.NewTicker(time.Duration(float64(time.Second) / float64(targetFPS)))
defer updateTicker.Stop()
for {
if totalFrames > 0 && curFrames >= totalFrames {
rt.Terminate()
return
}
select {
case <-updateTicker.C:
func() {
defer func() {
recover()
}()
select {
case rt.processQueue <- _Task{kind: _TaskKind_Frame, action: rt.frameLoop}:
curFrames++
case <-rt.ctx.Done():
}
}()
case <-rt.ctx.Done():
return
}
}
}
func (rt *RuntimeBehavior) frameLoop(...any) {
rt.frameLoopEnd()
rt.frameLoopBegin()
}
func (rt *RuntimeBehavior) frameLoopBegin() {
rt.changeRunningState(runtime.RunningState_FrameLoopBegin)
rt.changeRunningState(runtime.RunningState_FrameUpdateBegin)
emitEventUpdate(&rt.eventUpdate)
emitEventLateUpdate(&rt.eventLateUpdate)
rt.changeRunningState(runtime.RunningState_FrameUpdateEnd)
}
func (rt *RuntimeBehavior) frameLoopEnd() {
rt.changeRunningState(runtime.RunningState_FrameLoopEnd)
frame := runtime.UnsafeFrame(rt.opts.Frame)
frame.SetCurFrames(frame.GetCurFrames() + 1)
}