Redis 在节点中是“有前途的”吗？

Question

似乎和我使用的其他数据仓库不同，我在Redis中不能使用如下策略：

  export class CollectPromises {
       private cachePromises: Array<Promise<any>> = [];

        public addPromise(promise: Promise<any>): void {
           this.cachePromises.push(promise);
        };

        public async executeAllPromises(): Promise<void> {
            await Promise.all(this.cachePromises);
        };
    };

我在 Redis 中的函数：

    async function addSingleDataToSet(key: string, data: any): Promise<boolean> {
        return new Promise<boolean>((resolve, reject) => {


            RedisManager.redisClient.sadd([key].concat(data), ((err, res: number) => {
                if(err) {
                    reject(err);
                } else {
                    resolve(res == 1);
                }
            }));
        });
    };

    async function usingRedis(x, y): Promise<void> {
        await addSingleDataToSet(x, y);
    }

以及在 executeAllPromises() 之前不应该触发任何东西的实际代码（据我了解以及在其他存储库中发生的情况）

CollectPromises.addPromise(usingRedis(x, y));
CollectPromises.addPromise(usingRedis(a, b));
CollectPromises.addPromise(usingRedis(c, d));
await CollectPromiser.executeAllPromises();

问题是 CollectPromises.addPromise(usingRedis(x, y)) （与其他相同）在仅使用 Redis 发生的 executeAllPromises() 之前被触发。

我想知道我是做错了什么还是面临一些特定的 Redis/Node 问题。

Answer 1

Promise 在您创建它们的那一刻开始运行。在您的示例中，无论您是否调用 executeAllPromises，它们都会执行。

您可能会从引入Task 的概念中受益，该概念定义为返回承诺的函数。这样您就可以在需要时启动它们。

为此，您需要将usingRedis 更改为如下所示：

const usingRedis = (x, y) => () => addSingleDataToSet(x, y);

和executeAllPromises 需要调整以运行任务：

await Promise.all(this.cachePromises.map(task => task()));

然后在一堆地方重命名 Promise -> Task。