2

我需要实现一个微服务,在启动时将大量数据加载到内存中,并通过 HTTP GET 使这些数据可用。我一直将 fs2 视为通过fs2.Queue.

我担心的是,如果我使用synchronous来自 的队列fs2,由于队列的阻塞性质synchronous(在enqueue操作中),我提供数据的性能可能会受到负面影响。

这是一个有效的担忧吗?此外,哪些Queue抽象(在 fs2 中)是线程安全的?即:我可以将任何队列传递给多个线程,并且它们都可以安全地将项目从队列中取出,而不会有多个线程从队列中取出相同的元素吗?

编辑:用例:流服务的 1000 万条记录 -> 许多工作人员(线程)通过 HTTP 端点(GET)从流中挑选工作

4

0 回答 0