akka-http的不同执行上下文和线程分配

Question

val spotsJsonF: Future[String] = spotsF.map(spots => DebugFormatter.produceJson(text, spots._1, spots._2, env))

complete(spotsJsonF.map { t => HttpEntity(ContentTypes.`application/json`, t) })

null

    "default-dispatcher": {
      "attempt-teamwork": "on",
      "default-executor": {
        "fallback": "fork-join-executor"
      },
      "executor": "default-executor",
      "fork-join-executor": {
        "parallelism-factor": 3,
        "parallelism-max": 64,
        "parallelism-min": 8,
        "task-peeking-mode": "FIFO"
      },
      "mailbox-requirement": "",
      "shutdown-timeout": "1s",
      "thread-pool-executor": {
        "allow-core-timeout": "on",
        "core-pool-size-factor": 3,
        "core-pool-size-max": 64,
        "core-pool-size-min": 8,
        "fixed-pool-size": "off",
        "keep-alive-time": "60s",
        "max-pool-size-factor": 3,
        "max-pool-size-max": 64,
        "max-pool-size-min": 8,
        "task-queue-size": -1,
        "task-queue-type": "linked"
      },
      "throughput": 5,
      "throughput-deadline-time": "0ms",
      "type": "Dispatcher"
    },

Answer 1

对我来说，这听起来并不是关于管理线程，将繁重的工作隔离给一个单独的调度器，而是关于管理实际的处理。

为了能够在工作中停止一个长时间运行的进程，也就是说，您需要将它分成更小的块，以便在不再需要它时可以中途中止它。

actor的一个常见模式是让处理actor将结果存储为“so far”或将其作为消息发送给自己，这样它就可以对“stop working”消息做出反应，或者可能检查它是否已经处理了如此长的wall时间以至于它应该中止。例如，触发工作负载的消息可以包含这样一个超时值，以允许“客户端”指定它。