3

根据这个包https://github.com/OptimalBits/bull是否有可能中止“等待队列”中的某个任务?我的用例如下:

我有一个 mongodb 集合“用户”和一个集合“友谊”,我在其中存储两个用户的名称和头像。所以我只需要一个查询来获取某个用户的好友列表。当用户更改他的头像时,我必须在“友谊”集合中更新该用户中的所有文档。这是一个性能不重要的操作,因为我希望它在后台执行,并且一致性对于这个用例并不重要。但是当用户在短时间内多次更新他的头像时,我想取消所有引用旧任务(用于更新友谊集合),除了最新的。这与公牛可能吗?

在此先感谢,我将不胜感激有关此的所有信息。

4

1 回答 1

5

查看 Bull 参考资料,您会发现有一种Job.remove()方法。由于您尚未发布任何代码,我只能猜测它的外观。因此,我已经描述了您可以做什么。

但是,您要做的是将例如Promise<Job>将返回的内容存储在. String 将是您的用户,并且是一个数组,其中包含特定用户的所有排队作业。一旦 Job 已解决(您可以使用 等待已解决的作业),您需要从 Map 中删除 Promise。Queue.add()Map<string, Map<string, Promise<Job>>_idPromise<Job>[]Job.finished()

每当用户更改他的头像时,如果您需要删除任何工作,您可以查看您的地图。上面提到的 Map 中的 value 是另一个 Map(key 是一个字符串,代表JobId),它可以很容易地允许您通过 JobId 删除 Jobs。这听起来可能有点复杂,但不要害怕——如果您了解地图的工作原理,那应该不是问题 :-)。

于 2017-11-29T12:55:12.930 回答