scala Futures：是否有可能发现是否安装了“onFailure”回调（因此我们可以实现默认错误处理）？

Question

我的问题在某种程度上与Scala futures的默认错误处理程序相关。

奇怪的是，我想安装一个默认的错误处理程序，只有在Future上没有安装onFailure（或on完成）回调时才会启动。我认为这将非常有用，因为我编写的代码中我的Futures会无声地失败，让我对发生了什么感到困惑。后备错误处理程序将使我能够轻松地识别从未定义过适当的onFailure回调的错误Futures。

下面是一个代码示例，它说明了这在哪些方面可能有用。

  import scala.concurrent.ExecutionContext.Implicits.global
  import scala.concurrent._
  import scala.language.implicitConversions
  import scala.language.postfixOps

  def futureWithLogging[T](fut: Future[T]) =
    fut.transform(identity, { t: Throwable =>
      Console.err.println(s"failed with $t")
      t
    })


  {
    val f = futureWithLogging ( Future {
      Thread.sleep(1000)
      throw new scala.RuntimeException("")
    } )

    f.onFailure{ case err:Throwable => {println("custom error message"); err.printStackTrace()} }

    println(s"future value is: ${f.value}")
    Thread.sleep(1000)
    println(s"future value is now: ${f.value}")
    Thread.sleep(1000)
  }

请注意，我有一个futureWithLogging函数，它会在您传递给该函数的任何future上安装一些默认的错误处理行为。现在，如果我忘记在未来安装一个onFailure，这是非常方便的。但是在上面的代码中，你可以看到我在Future 'f '上安装了一个onFailure处理程序。结果是我的日志中有噪音。我看到两条错误消息:

  failed with <exception>  

和

   custom error message...

在这种情况下，我只想看到第二个

非常感谢您提供的任何指导！

Answer 1

最接近我想要的，是让任何特定的故障处理程序将异常包装在一个特殊的“HandledException”包装器中，默认的失败处理程序可以特别处理（忽略，或打印合适的消息，或者其他什么）。例如：

import scala.concurrent.ExecutionContext.Implicits.global
import scala.concurrent._
import scala.language.implicitConversions
import scala.language.postfixOps

case class HandledException(inner: Throwable) extends RuntimeException(inner)

def futureWithLogging[T](fut: Future[T]) =
  fut.transform(identity, { t: Throwable =>
    Console.err.println(s"failed with $t")
    HandledException(t)
  })


{
  val f = futureWithLogging ( Future {
    Thread.sleep(1000)
    throw new scala.RuntimeException("")
  } )

  f.onFailure {
    case HandledException(inner) => println("Already handled: "+inner)
    case err:Throwable => {println("custom error message"); err.printStackTrace()}
  }

  println(s"future value is: ${f.value}")
  Thread.sleep(1000)
  println(s"future value is now: ${f.value}")
  Thread.sleep(1000)
}

从这里，您可以向“HandledException”类添加一个问题ID，它可以在首次捕获初始异常的地方打印出来，然后传递给前端（并且可能在途中通过诸如默认处理程序之类的东西打印出短手）并向用户显示一条消息，例如“对不起，我们遇到了一个错误——您可以向我们的支持人员发送电子邮件，引用问题ID'...'寻求帮助”或任何您喜欢的信息。此ID可以存储在DB中，通过日志文件进行跟踪（如果合适，可能会放入日志框架的诊断上下文中）等。