我有一个非常简单的Maven
spring MVC项目,我添加了
Scala.我希望以下三个期货能够按预期同时执行.然而,他们一个接一个地执行
val viewName: Future[String] = for { profileSync <- Future { EmployeeLocalServiceUtil.syncProfileinformation() } earningsSync <- Future { EmployeeLocalServiceUtil.syncEarnings() } reimbursementSync <- Future { EmployeeLocalServiceUtil.syncReimbursements() } } yield { "employee/view" }
我的机器有4个核心,我正在使用scala.concurrent.ExecutionContext.Implicits.global上下文.除此之外,没有可以阻止/启用期货并行执行的配置.
解决方法
因为理解只是语法糖而且是
translated to flatMap like in Example 2.
这意味着您的代码大致如下所示:
Future { ??? }.flatMap { profileSync => Future { ??? }.flatMap { earningsSync => Future { ??? }.map { reimbursementSync => // Able to access profileSync/earningsSync/reimbursementSync values. "employee/view" } } }
如您所见,期货仅在上一次完成后推出.为了解决这个问题,首先启动你的期货,然后进行理解:
val profileSyncFuture = Future { EmployeeLocalServiceUtil.syncProfileinformation() } val earningsSyncFuture = Future { EmployeeLocalServiceUtil.syncEarnings() } val reimbursementSyncFuture = Future { EmployeeLocalServiceUtil.syncReimbursements() } val viewName: Future[String] = for { profileSync <- profileSyncFuture earningsSync <- earningsSyncFuture reimbursementSync <- reimbursementSyncFuture } yield { "employee/view" }
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。