等待具有内部回调的同步函数

Question

我有一些同步函数，其中有些不是我自己的代码。这些函数在完成后接受并执行回调函数。

我需要等待这些回调完成，然后退出应用程序。我怎么才能强制执行呢？

const serverGracefulShutdown = () => {

  logger.info('Signal received: Gracefully killing application');

  httpServer.close(() => {
    logger.info('Apollo server closed');
  });

  redis.quit(() => {
    logger.info('Redis client closed');
  });

  stopKafkaConsumer(() => {
    logger.info('Kafka consumer closed');
  });

  logger.info('Application closed');
  process.exit(0);
};

process.on('SIGINT', serverGracefulShutdown);
process.on('SIGTERM', serverGracefulShutdown);

在上面的代码中，我希望确保应用程序的优雅关闭。

所有正在运行的东西都停止了，然后我可以调用process.exit(0)。

Answer 1

你应该能够履行诺言：

const serverGracefulShutdown = () => {

  logger.info('Signal received: Gracefully killing application');

  const promises = [

    new Promise((resolve, reject) => httpServer.close(() => {
      // do you get an optional error param inside this callback?
      // if yes, then "if (error) reject(error) else resolve()"
      // (or any other way to mark this operation as failed)
      logger.info('Apollo server closed');
      resolve();
    })),

    new Promise((resolve /* + reject? */) => redis.close(() => {
      logger.info('Redis client closed');
      resolve();
    })),

    new Promise((resolve /* + reject? */) => stopKafkaConsumer(() => {
      logger.info('Kafka consumer closed');
      resolve();
    }))

  ];

  return Promise.all(promises).then(() => {
    logger.info('Application closed');
    process.exit(0);
  }).catch((error) => {
    // what's your plan if at least one failed?
  });

};

process.on('SIGINT', serverGracefulShutdown);
process.on('SIGTERM', serverGracefulShutdown);