google-app-engine - 任务队列完成回调

Question

我正在使用谷歌云任务队列来执行一些长时间运行的任务。完成所有任务后，我想发送一些通知。

我正在使用下面的代码来获取线程中待处理任务的数量

QueueStatistics stats= taskQueue.fetchStatistics(); stats.getNumTasks();

但在这里我不断检查 getNumTask() 方法返回的值。如果它为零，那么我会通知其他人。是否有任何可用的回调可以在我队列中的所有任务完成后通知我。

问候，

Answer 1

如果并发运行的任务不是您的应用程序必须的，您可以设置队列并将 max-concurrent-requests 设置为 1，这样任务将一个接一个地运行:

<queue-entries>
  <queue>
    <name>my-queue</name>
    <rate>1/s</rate>
    <max-concurrent-requests>1</max-concurrent-requests>
  </queue>
</queue-entries>

然后，在推送队列中的所有任务后，将通知任务推送到同一队列。通知任务将是队列中的最后一个任务，将在所有任务完成后执行。

注意:当您的一项任务失败时，请小心自动重试。这将使通知任务不是队列中的最后一个任务。也许您可以在失败时清除队列，然后重试。