MCPcopy Create free account
hub / github.com/alexankitty/Myrient-Search-Engine / constructor

Method constructor

lib/utility/taskqueue.js:2–15  ·  view source on GitHub ↗
(
    maxTasksPerSecond = 4,
    maxSimultaneousTasks = 8,
    maxQueueLength = 20
  )

Source from the content-addressed store, hash-verified

1export default class TaskQueue {
2 constructor(
3 maxTasksPerSecond = 4,
4 maxSimultaneousTasks = 8,
5 maxQueueLength = 20
6 ) {
7 this.maxTasksPerSecond = maxTasksPerSecond;
8 this.maxQueueLength = maxQueueLength;
9 this.maxSimultaneousTasks = maxSimultaneousTasks;
10 this.queue = [];
11 this.processing = false;
12 this.lastProcessTime = 0;
13 this.taskCount = 0;
14 this.tasksWaiting = 0;
15 }
16
17 async enqueue(taskFunction, that = this, ...args) {
18 return new Promise((resolve, reject) => {

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected