PHP WebShell

• .. (вверх)
• [DIR] ..
• [FILE] caching.ts
• [FILE] parallel.ts
• [FILE] queue.ts
• [FILE] serial.ts

Просмотр файла: queue.ts

// Copyright (c) Mysten Labs, Inc.
// Modifications Copyright (c) 2024 IOTA Stiftung
// SPDX-License-Identifier: Apache-2.0

export class SerialQueue {
    #queue: Array<() => void> = [];

    async runTask<T>(task: () => Promise<T>): Promise<T> {
        return new Promise((resolve, reject) => {
            this.#queue.push(() => {
                task()
                    .finally(() => {
                        this.#queue.shift();
                        if (this.#queue.length > 0) {
                            this.#queue[0]();
                        }
                    })
                    .then(resolve, reject);
            });

            if (this.#queue.length === 1) {
                this.#queue[0]();
            }
        });
    }
}

export class ParallelQueue {
    #queue: Array<() => void> = [];
    activeTasks = 0;
    maxTasks: number;

    constructor(maxTasks: number) {
        this.maxTasks = maxTasks;
    }

    runTask<T>(task: () => Promise<T>): Promise<T> {
        return new Promise<T>((resolve, reject) => {
            if (this.activeTasks < this.maxTasks) {
                this.activeTasks++;

                task()
                    .finally(() => {
                        if (this.#queue.length > 0) {
                            this.#queue.shift()!();
                        } else {
                            this.activeTasks--;
                        }
                    })
                    .then(resolve, reject);
            } else {
                this.#queue.push(() => {
                    task()
                        .finally(() => {
                            if (this.#queue.length > 0) {
                                this.#queue.shift()!();
                            } else {
                                this.activeTasks--;
                            }
                        })
                        .then(resolve, reject);
                });
            }
        });
    }
}

Выполнить команду