IO应用程序未关闭执行的原因是什么？

Question

为什么要挂？

import cats.effect.IO
import cats.effect.unsafe.implicits.global
import com.typesafe.config.ConfigFactory
import io.circe.config.parser
import org.typelevel.log4cats._
import org.typelevel.log4cats.slf4j._

object ItsElenApp extends App:

  private val logger: SelfAwareStructuredLogger[IO] = LoggerFactory[IO].getLogger

  val ops = for
    _ <- logger.info("aa")
    _ <- IO(println("bcc"))
    _ <- logger.error("bb")
  yield ()

  ops.unsafeRunSync()

  println("end")

它打印：

INFO 2022-06-19 11:56:25,303 ItsElenApp - aa
bcc

保持运行。是log4cats库，还是我以错误的方式使用应用程序对象。还是我必须关闭执行上下文？

Answer 1

推荐的运行cats.effect.io基于基于的应用程序的方法是cats.effect.ioapp（或cats.effect.resourceapp）：

object MyApp extends IOApp:

  // notice it takes List[String] rather than Array[String]
  def run(args: List[String]): IO[ExitCode] = ...

this would run the application, handle setting up exit code, etc.

另一方面不建议扩展app。为什么？它使用特殊的延迟机制，其中全部（其构造函数）懒惰。这使得初始化更加困难，这就是为什么这种机制被贬低/灰心的原因。如果您不使用IOAPP，最好实施类似的事情：

object MyProgram:

  // Java requires this signature
  def main(args: Array[String]): Unit = ...

在您的情况下看起来像是

object ItsElenApp:

  private val logger: SelfAwareStructuredLogger[IO] = LoggerFactory[IO].getLogger

  def main(args: Array[String]): Unit =
    val ops = for
      _ <- logger.info("aa")
      _ <- IO(println("bcc"))
      _ <- logger.error("bb")
    yield ()

    // IOApp could spare you this
    try
      ops.unsafeRunSync()
    finally
      println("end")
      sys.exit(0)

Answer 2

因为Log4Cats的记录功能似乎是异步的。这意味着它们可能会在另一个线程上运行，而不是与其他操作序列。

这意味着主螺纹可能会完成，但是其他线程不断打开并且永不关闭。

如果我使用ops.unsaferuntimed（2.seconds）所有内容都执行并关闭。但是后一个日志线仅在结束时出现。看来记录是某种程度上懒惰的，只有在要求它的情况下才能完成。我不知道。

他们写作，您不应在生产代码中使用 。

当然，如果您使用ioApp，则一切都会再次正常执行。

但是，如果没有ioApp，您将如何在生产代码中编写此此内容？我认为应该有一种干净的方式告诉log4cats完成操作，返回其异步纤维结果并关闭所有内容。全部手动。