4

我有一个简单的猫效应应用程序，它从作为参数给出的 URL 下载站点。在下载应用程序期间，应该通过将点 ( .) 写入控制台来显示“加载栏”。我通过两个IO的竞赛来实现它，一个用于下载另一个用于显示点。

这是scastie上的整个应用程序。

最重要的部分在这里：

def loader(): IO[Unit] = for {
      _ <- console.putStr(".")
      _ <- timer.sleep(Duration(50, MILLISECONDS)) *> loader()
    } yield {}


  def download(url: String): IO[String] = IO.delay(Source.fromURL(url)).map(_.mkString)

  def run(args: List[String]): IO[Unit] = {

    args.headOption match {
      case Some(url) =>
        for {
          content <- IO.race(download(url), loader()).map(_.left.get)
          _ <- console.putStrLn() *> console.putStrLn(s"Downloaded site from $url. Size of downloaded content is ${content.length}.")
        } yield {}

      case None => console.putStrLn("Pass url as argument.")
    }
  }

一切都按我的预期工作，当我运行它时，我得到：

............. 从https://www.scala-lang.org下载的站点。下载内容的大小为 47738。

唯一的问题是应用程序永远不会退出。

据我检查加载器 IO被正确取消。我什至可以添加如下内容：

urlLoader.run(args) *> console.putStrLn("???") *> IO(ExitCode.Success)

并???显示出来。

此外，当我删除race时，应用程序会正确退出。

所以我的问题是如何解决这个问题并让我的应用程序最终退出？

4

1 回答 1

3

跟进我上面的评论：问题是您的ScheduledExecutorService线程正在运行，阻止 JVM 退出，即使您的计时器任务已被取消。有几种方法可以解决这个问题：

  • IO(ses.shutdown())在IO(ExitCode.Success). _
  • newScheduledThreadPool使用守护其线程的线程工厂调用。
  • 使用timer: Timer您在里面免费获得的IOApp。

最后一个几乎绝对是正确的选择 - 使用ContextShift提供的计时器（和）IOApp将为您提供此行为和其他行为的合理默认值。

于 2019-06-23T13:33:14.723 回答