在Scala中用副作用期货组合无状态期货

Question

在用收益结构组合期货时，有些有副作用，有些没有，我引入了竞争条件，因为取决于副作用的未来并没有将副作用的结果作为论据。

简而言之：

未来b读取由来自未来a的副作用改变的值，但是未来a不明确依赖于未来b的结果，因此可能在b完成读取之前发生。

为了解决这个问题，我的同事引入了一个虚拟函数，将b的结果作为参数并简单地将其丢弃。这样做是为了使依赖显式化。

实际代码如下：

  val futureConnection:Future[(Either[String, (Connection)],Boolean)] =
    for {
      scannerUser <- scanner.orFail("Scanning user not found")
      scannedUser <- futureScannedUser.orFail("Scanned user not found")
      existsInAnyDirection <- connections.existsInAnyDirection(scannerUser, scannedUser)
      connection <- connections.createConnection(scannerUser, scannedUser, form.magicWord, existsInAnyDirection)
    } yield {
      (connection, existsInAnyDirection)
    }

在这种情况下，未来 b 为

connections.existsInAnyDirection（scannerUser， scannedUser）

带哑参数的未来a是

< code > connections . create connection(scanner user，scannedUser，form.magicWord，existsInAnyDirection)

请注意，参数< code > existsInAnyDirection 从未在< code>createConnection中使用。这有效地创建了依赖图，即在existsInAnyDirection完成之前不能启动createConnection。

现在的问题是：

奖金信息

我自己的挖掘告诉我，Scala的未来不能很好地处理副作用。处理副作用的Future trait上的方法返回单元，而从副作用操作中很可能会读取结果，即错误代码、生成的ID、任何其他元信息。

Answer 1

Future正在处理延迟计算的副作用，如A=

您尝试混合几种不同的副作用，但只组合了其中一种Future[_]。

尝试选择第二个容器，这可以是产品或状态，取决于您的副作用并考虑副作用的组合方式（可能是您需要modand transvers）。在您的代码之后可以看起来像（最简单的情况）：

for {
  scannerUser <- scanner.orFail("Scanning ...")
  (scannedUser, magicWord) <- futureScannedUser.orFail("Scanned ...")      
  connection <- connections.createConnection(scannerUser, scannedUser, magicWord)
} yield {
  (connection, existsInAnyDirection)
}

// OR

for {
  (scannerUser, state) <- scanner.orFail("Scanning ...")
  (scannedUser, nextState) <- futureScannedUser(state).orFail("Scanned ...")      
  connection <- connections.createConnection(scannerUser, scannedUser, nextState)
} yield {
  (connection, existsInAnyDirection)
}