2

我最近将我的应用程序转换为继承猫的应用程序，如此处IOApp所述。我在那个文档中读到：

Timer[IO] 依赖项已由 IOApp 提供，因此在 JVM 之上不再需要隐式 ExecutionContext 在范围内

但是，我正在与其他几个需要ExecutionContext. 在这种类型的应用程序中是否有推荐的获取方法？提供的好老人import scala.concurrent.ExecutionContext.Implicits.global玩得Timer[IO]好吗？

4

1 回答 1

4

尝试扩展 trait IOApp.WithContext。对于全球ExecutionContext

import cats.effect._
import scala.concurrent.ExecutionContext

object Main extends IOApp.WithContext {
  implicit val ec = ExecutionContext.global

  override protected def executionContextResource: Resource[SyncIO, ExecutionContext] =
    Resource.liftF(SyncIO(ec))

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

    implicitly[Timer[IO]]
    implicitly[ContextShift[IO]]
    implicitly[ExecutionContext]

    IO.pure(ExitCode.Success)
  }
}

或ExecutionContext来自具有固定线程数的线程池

import java.util.concurrent.{Executors, TimeUnit}
import cats.effect._
import scala.concurrent.ExecutionContext

object Main extends IOApp.WithContext {
  override protected def executionContextResource: Resource[SyncIO, ExecutionContext] =
    Resource.make(SyncIO(Executors.newFixedThreadPool(8)))(pool => SyncIO {
      pool.shutdown()
      pool.awaitTermination(10, TimeUnit.SECONDS)
    }).map(ExecutionContext.fromExecutorService)

  def run(args: List[String]): IO[ExitCode] = {
    executionContextResource.use { implicit ec =>

      implicitly[Timer[IO]]
      implicitly[ContextShift[IO]]
      implicitly[ExecutionContext]

      SyncIO.pure(ExitCode.Success)
    }.toIO
  }
}

https://github.com/typelevel/cats-effect/issues/337

https://github.com/typelevel/cats-effect/pull/344

于 2019-11-12T09:01:17.673 回答