有没有办法让akka的mapAsync中的函数超时呢？

import akka.actor.{Actor, ActorSystem, Props}
import akka.pattern.ask
import akka.util.Timeout

import scala.concurrent.Future
import scala.concurrent.duration._

// 目标actor
class MyActor extends Actor {
  import context.dispatcher

  def receive: Receive = {
    case msg: String =>
      // 模拟一个耗时的操作
      val result = performOperation(msg)

      // 返回结果
      sender() ! result
  }

  // 模拟一个耗时的操作
  def performOperation(msg: String): String = {
    // 模拟一个耗时的操作
    Thread.sleep(5000)

    s"Processed: $msg"
  }
}

object Main extends App {
  // 创建actor系统
  val system = ActorSystem("MySystem")

  // 创建目标actor
  val myActor = system.actorOf(Props[MyActor])

  // 设置超时时间
  implicit val timeout: Timeout = Timeout(3.seconds)

  // 发送消息并等待响应
  val future: Future[Any] = (myActor ? "Hello").mapTo[String]

  // 处理超时情况
  future.onComplete { result =>
    result match {
      case scala.util.Success(response) =>
        println(s"Received response: $response")
      case scala.util.Failure(ex) =>
        println("Request timed out")
    }
    system.terminate()
  }
}