Git-Mirrors/haveno-ts
1
0
Fork 0
mirror of https://github.com/haveno-dex/haveno-ts.git synced 2025-01-12 07:49:52 -05:00
Code Issues Packages Projects Releases Wiki Activity

TaskLooper does not target fixed period by default

Browse Source
This commit is contained in:
woodser 2024-04-25 16:52:24 -04:00
parent 4ea5025393
commit 6b289ccd78
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/utils/TaskLooper.ts
View File

@ -39,13 +39,15 @@ export default class TaskLooper {
/** /**
* Start the task loop. * Start the task loop.
* *
* @param {int} periodInMs the loop period in milliseconds * @param {number} periodInMs the loop period in milliseconds
* @param {boolean} targetFixedPeriod specifies if the task should target a fixed period by accounting for run time (default false)
* @return {TaskLooper} this instance for chaining
*/ */
start(periodInMs: number) { start(periodInMs: number, targetFixedPeriod: boolean) {
if (periodInMs <= 0) throw new Error("Looper period must be greater than 0 ms"); if (periodInMs <= 0) throw new Error("Looper period must be greater than 0 ms");
if (this._isStarted) return; if (this._isStarted) return;
this._isStarted = true; this._isStarted = true;
this._runLoop(periodInMs); this._runLoop(periodInMs, targetFixedPeriod);
} }
/** /**
@ -58,12 +60,12 @@ export default class TaskLooper {
this._timeout = undefined; this._timeout = undefined;
} }
async _runLoop(periodInMs: number) { async _runLoop(periodInMs: number, targetFixedPeriod: boolean) {
this._isLooping = true; this._isLooping = true;
while (this._isStarted) { while (this._isStarted) {
const startTime = Date.now(); const startTime = Date.now();
await this._fn(); await this._fn();
if (this._isStarted) await new Promise((resolve) => { this._timeout = setTimeout(resolve, periodInMs - (Date.now() - startTime)); }); if (this._isStarted) await new Promise((resolve) => { this._timeout = setTimeout(resolve, periodInMs - (targetFixedPeriod ? (Date.now() - startTime) : 0)); });
} }
this._isLooping = false; this._isLooping = false;
} }