应该是一个简单的问题。我正在使用Akka 2.4.2（包含Akka流和HTTP）。我希望此操作Source能够完成并终止该程序，因为该操作Source是有限的，但它永远不会终止。为什么该程序不终止？
import scala.concurrent._
import scala.collection.immutable._
import akka._
import akka.actor._
import akka.stream._
import akka.stream.scaladsl._
import akka.util._
object Test extends App {
implicit val system = ActorSystem("TestSystem")
implicit val materializer = ActorMaterializer()
val s = Source.single(1)
s.runForeach(println)
}
输出：
$ sbt run
...
[info] Running Test
[DEBUG] [02/23/2016 10:59:19.904] [run-main-0] [EventStream(akka://TestSystem)] logger log1-Logging$DefaultLogger started
[DEBUG] [02/23/2016 10:59:19.904] [run-main-0] [EventStream(akka://TestSystem)] Default Loggers started
1
我build.sbt文件的相关部分：
scalaVersion := "2.11.7"
scalacOptions := Seq("-unchecked", "-deprecation", "-encoding", "utf8")
libraryDependencies ++= {
val akkaVersion = "2.4.2"
Seq(
"com.typesafe.akka" %% "akka-stream" % akkaVersion
)
}
由于Akka使用非守护线程，因此它将保持应用程序运行，直到您关闭ActorSystem。那是因为典型的用例是在您的main方法中启动系统，然后所有计算都在ActorSystem管理的main()线程上进行（即该线程要完成并消失-如果这些线程是守护进程，则该应用会关闭，这不是我们通常想要的）。
您可以通过以下方式进行操作：
import system.dispatcher
s.runForeach(println).onComplete { _ => system.terminate() }
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句