使用源队列实现线程的akka-http中的连接池安全吗？

Question

关于中提到的以下实施：

http://doc.akka.io/docs/akka-http/10.0.5/scala/http/client-side/host-level.html

val poolClientFlow = Http().cachedHostConnectionPool[Promise[HttpResponse]]("akka.io")
val queue =
  Source.queue[(HttpRequest, Promise[HttpResponse])](QueueSize, OverflowStrategy.dropNew)
    .via(poolClientFlow)
    .toMat(Sink.foreach({
      case ((Success(resp), p)) => p.success(resp)
      case ((Failure(e), p))    => p.failure(e)
    }))(Keep.left)
    .run()

从多个线程提供队列http请求是线程安全的吗？如果不是，那么执行这种要求的最佳方法是什么？也许用一个有奉献精神的演员？

Answer 1

不，它不是线程安全的，根据api文档:sourcequeue，当前源物化到的仅用于单线程。

一个专用的执行元可以很好地工作，但如果可以，使用source.actorref（文档链接）而不是source.queue会更容易。

通常，source.actorref的缺点是缺乏背压，但是当您使用overflowstrategy.dropnew时，很明显您并不期望有背压。因此，您可以使用source.actorref获得相同的行为。