如何在Scala中使用Phantom-dsl从Apache Cassandra同步检索数据？

Question

我使用的是Scala_2.11.7、Apache Cassasndra_3.9和Phantom-dsl_2.6.1。当我使用phantom从Cassandra检索数据时，phantom总是在Future中返回数据。但是我想要同步的结果。有没有办法使用phantom从cassandra同步检索数据？

Answer 1

如果您希望执行是同步的，则必须阻塞调用线程，并等待将来完成。这是(正如scala lang doc所说的)“强烈反对”，因为性能严重受损。

如果您有一个返回FutureT的函数，则可以使用Await.result，例如：

import scala.concurrent._
import scala.concurrent.duration._

val fresult : Future[Int] = getRecord()

val result: Int = Await.result(fresult, 5 seconds)