mongodb - MongoDB 上的并发读取操作

Question

我有一个 scala 应用程序，它正在通过 4 个线程访问包含 1300 万条记录的 Mongo 集合。

我希望四个线程​​同时访问 Mongo，并希望确保它们永远不会读取相同的记录。此外，线程 2 在传递 3 中访问的记录将来不应被任何其他线程访问。

关于如何实现它有什么建议吗？

Answer 1

它看起来是一个调度器功能的好地方。

Dispatcher 需要读取所有 id，然后使用比方说 roundRobin 队列将 id 推送到 f1,f2,f3,f4。没有阻止从单个文档读取数据的锁定机制，因此当 id 被分派(dispatch)时，底层函数将必须执行所有操作。