2022-03-25 11:14:49 +00:00
|
|
|
import { Task } from './taskbuffer.classes.task.js';
|
2019-09-23 16:06:43 +00:00
|
|
|
|
|
|
|
export class BufferRunner {
|
|
|
|
public task: Task;
|
2023-08-01 22:07:21 +00:00
|
|
|
// initialize by default
|
2019-09-23 16:06:43 +00:00
|
|
|
public bufferCounter: number = 0;
|
2023-08-01 22:07:21 +00:00
|
|
|
|
2023-08-02 00:30:13 +00:00
|
|
|
constructor(taskArg: Task<any>) {
|
2019-09-23 16:06:43 +00:00
|
|
|
this.task = taskArg;
|
|
|
|
}
|
|
|
|
|
2021-09-26 12:45:02 +00:00
|
|
|
public trigger(x: any): Promise<any> {
|
2019-09-23 16:06:43 +00:00
|
|
|
if (!(this.bufferCounter >= this.task.bufferMax)) {
|
|
|
|
this.bufferCounter++;
|
|
|
|
}
|
|
|
|
const returnPromise: Promise<any> = this.task.cycleCounter.getPromiseForCycle(
|
2023-08-01 22:07:21 +00:00
|
|
|
this.bufferCounter
|
2019-09-23 16:06:43 +00:00
|
|
|
);
|
2020-09-07 17:35:50 +00:00
|
|
|
if (!this.task.running) {
|
2019-09-23 16:06:43 +00:00
|
|
|
this._run(x);
|
|
|
|
}
|
|
|
|
return returnPromise;
|
|
|
|
}
|
|
|
|
|
2023-08-01 22:07:21 +00:00
|
|
|
private async _run(x: any) {
|
|
|
|
this.task.running = true;
|
|
|
|
while (this.bufferCounter > 0) {
|
|
|
|
const result = await Task.runTask(this.task, { x: x });
|
|
|
|
this.bufferCounter--;
|
|
|
|
this.task.cycleCounter.informOfCycle(result);
|
|
|
|
}
|
|
|
|
this.task.running = false;
|
2019-09-23 16:06:43 +00:00
|
|
|
}
|
2019-11-28 11:33:26 +00:00
|
|
|
}
|