- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我正在尝试使用 monix 来并行化某些操作,然后执行错误处理
假设我正在尝试解析和验证这样的几个对象
def parseAndValidateX(x: X) Task[X]
和
def parseAndValidateY(y: Y): Task[Y]
这里 X 和 Y 是我定义的一些类型。
Task.raiseError(new CustomException("X is invalid because certain reasons a,b,c"))
我对 Y 有类似的任务加薪。
Task.raiseError(new CustomException("Y is invalid because certain reasons a',b',c'"))
现在我有这种类型
case class Combined(x: X, y: Y)
我定义了这个
private def parseAndValidateCombined(x: X, y: Y): Task[Combined] = {
val xTask = parseAndValidateX(x)
val yTask = parseAndValidateY(y)
Task.parMap2(xTask, yTask) {
(xEval, yEval) => SecretData(xEval, yTask)
}
}
这应该允许我并行运行验证,并且我确实得到了响应。
Task.raiseError(new CustomException("X is invalid because certain reasons a,b,c and "Y is invalid because certain reasons a',b',c'"))
我似乎无法做到这一点。根据两个任务中的哪一个失败,我只能在 parMap2 输出的 onRecover 方法上获得两个失败之一。
最佳答案
与 parMap2
只是,不可能完成你想做的事情。
documentation说:
In case one of the tasks fails, then all other tasks getcancelled and the final result will be a failure.
materialize
实现方法。
private def parseAndValidateCombined[X, Y](x: X, y: Y): Task[Combined] = {
val xTask = parseAndValidate(x).materialize // turn on Task[Try[X]]
val yTask = parseAndValidate(y).materialize // turn on Task[Try[Y]]
Task.parMap2(xTask, yTask) {
case (Success(xEval), Success(yEval)) => Success(SecretData(xEval, yEval))
case (Failure(_), Failure(_)) => Failure[Combined](new CustomException(....))
case (Failure(left), _) => Failure[Combined](left)
case (_, Failure(right)) => Failure[Combined](right)
}.dematerialize // turn to Task[Combined]
}
我希望我能帮助你:)
关于scala - Monix 并行任务的错误处理(使用 parMap),我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/68538818/
我有一个康威生命游戏的实现。如果可能的话,我想通过使用并行性来加速它。 life :: [(Int, Int)] -> [(Int, Int)] life cells = map snd . filt
我试图用一个非常简单的例子来比较 parMap 与 map: import Control.Parallel.Strategies import Criterion.Main sq x = x^2 a
我已经运行了一些测试: import Control.Parallel.Strategies import Data.Vector as V import Data.Maybe parMapVec :
我已经运行了一些测试: import Control.Parallel.Strategies import Data.Vector as V import Data.Maybe parMapVec :
我有一个基本上执行以下操作的计算: f :: [a] -> ([b],Bool) 这个函数其实可以写 f = foldr h ([],False) . map g where h (b,boo
我有一个单子(monad)函数getRate: getRate :: String -> IO Double 我想将此函数映射到字符串列表。通常,我会这样做: mapM getRate ["foo",
对并行策略有疑问,parMap (控制.并行.策略) 大约是 parMap rseq等价于 parMap rpar . 由于parMap使用 parList它并行计算,因此使用 rseq或 rpar将
我正在尝试使用 monix 来并行化某些操作,然后执行错误处理 假设我正在尝试解析和验证这样的几个对象 def parseAndValidateX(x: X) Task[X] 和 def parseA
我是一名优秀的程序员,十分优秀!