Scala期货和线程

发布时间：2020-12-16 18:48:56 所属栏目：安全来源：网络整理

导读：阅读 scala.concurrent.Future和scala.concurrent.impl.Future的scala源代码,似乎通过map的每个未来组合都会为执行程序调度一个新任务.我假设这通常会触发当前线程的上下文切换,和/或作业线程的分配. 考虑到函数流需要在它们之间传递Futures以在没有阻塞的情

阅读 scala.concurrent.Future和scala.concurrent.impl.Future的scala源代码,似乎通过map的每个未来组合都会为执行程序调度一个新任务.我假设这通常会触发当前线程的上下文切换,和/或作业线程的分配.

考虑到函数流需要在它们之间传递Futures以在没有阻塞的情况下对Futures的结果起作用(或者没有深入研究回调意大利面),当代码以模块化方式编写时,这种“反应性”范式在实践中是不是非常昂贵每个函数只做一些小的东西并传递给其他函数？

解决方法

这取决于执行上下文.所以你可以选择策略.

你是执行者也可以在调用线程中执行它,将map调用保持在同一个线程上.您可以通过显式传递执行上下文或使用隐式来传递您自己的策略.

我首先通过记录使用的线程来测试默认的fork / join池的功能. Afaik的新版本有时会使用提交线程.但是,我不知道是否使用/应用了scala未来的回调.

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!