alois/OpenFrontIO
1
0
Fork 0
mirror of https://github.com/openfrontio/OpenFrontIO.git synced 2026-06-21 23:31:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

ClientGameRunner: simplify catch-up loop with indexed queue

Browse Source 
process updates in a single budgeted loop per RAF and render once
track queue head with pendingStart and compact to avoid array shifts
This commit is contained in:
scamiv
2025-11-24 22:54:09 +01:00
parent 5c99ef5092
commit 73f47fe997
1 changed files with 25 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/client/ClientGameRunner.ts
+25 -12
View File
@@ -215,6 +215,7 @@ export class ClientGameRunner {
private backlogGrowing: boolean = false;
private pendingUpdates: GameUpdateViewData[] = [];
private pendingStart = 0;
private isProcessingUpdates = false;
// Adaptive rendering when frames are heavy: render at most once every N frames.
@@ -477,12 +478,13 @@ export class ClientGameRunner {
}
private processPendingUpdates() {
if (this.isProcessingUpdates || this.pendingUpdates.length === 0) {
const pendingCount = this.pendingUpdates.length - this.pendingStart;
if (this.isProcessingUpdates || pendingCount <= 0) {
return;
}
this.isProcessingUpdates = true;
const processSlice = () => {
const processFrame = () => {
const BASE_SLICE_BUDGET_MS = 8; // keep UI responsive while catching up
const MAX_SLICE_BUDGET_MS = 1000; // allow longer slices when backlog is large
const BACKLOG_FREE_TURNS = 10; // scaling starts at this many turns
@@ -501,15 +503,16 @@ export class ClientGameRunner {
BASE_SLICE_BUDGET_MS +
backlogScale * (MAX_SLICE_BUDGET_MS - BASE_SLICE_BUDGET_MS);
const sliceStart = performance.now();
const frameStart = performance.now();
const batch: GameUpdateViewData[] = [];
let processedCount = 0;
let lastTickDuration: number | undefined;
let lastTick: number | undefined;
while (this.pendingUpdates.length > 0) {
const gu = this.pendingUpdates.shift() as GameUpdateViewData;
let processedCount = 0;
// Consume updates until we hit the time budget or per-slice cap.
while (this.pendingStart < this.pendingUpdates.length) {
const gu = this.pendingUpdates[this.pendingStart++];
processedCount++;
batch.push(gu);
@@ -528,13 +531,23 @@ export class ClientGameRunner {
}
lastTick = gu.tick;
const elapsed = performance.now() - sliceStart;
const elapsed = performance.now() - frameStart;
if (processedCount >= MAX_PER_SLICE || elapsed >= sliceBudgetMs) {
break;
}
}
if (processedCount > 0 && lastTick !== undefined) {
// Compact the queue if we've advanced far into it.
if (
this.pendingStart > 0 &&
(this.pendingStart > 1024 ||
this.pendingStart >= this.pendingUpdates.length / 2)
) {
this.pendingUpdates = this.pendingUpdates.slice(this.pendingStart);
this.pendingStart = 0;
}
if (batch.length > 0 && lastTick !== undefined) {
const combinedGu = this.mergeGameUpdates(batch);
if (combinedGu) {
this.gameView.update(combinedGu);
@@ -554,14 +567,14 @@ export class ClientGameRunner {
this.currentTickDelay = undefined;
}
if (this.pendingUpdates.length > 0) {
requestAnimationFrame(processSlice);
if (this.pendingStart < this.pendingUpdates.length) {
requestAnimationFrame(processFrame);
} else {
this.isProcessingUpdates = false;
}
};
requestAnimationFrame(processSlice);
requestAnimationFrame(processFrame);
}
private adaptRenderFrequency(frameDuration: number) {