Vad*_*dim 4 scala spring-data-jpa scala-cats
我有一个简单的 IO 操作序列,暂停 5 秒。
implicit val timer = IO.timer(ExecutionContext.global)
def doSth(str: String): IO[Unit] = IO(println(str))
def greeting(): IO[Unit] =
doSth("Before timer.") *>
Timer[IO].sleep(5 second) *>
doSth("After timer")
val a = greeting().unsafeRunAsyncAndForget()
Run Code Online (Sandbox Code Playgroud)
如何使计时器没有ExecutionContext.global,IOApp或固定线程数量ExecutionContext.global?
尝试
implicit val timer = IO.timer(ExecutionContext.fromExecutor(Executors.newFixedThreadPool(10)))
Run Code Online (Sandbox Code Playgroud)
| 归档时间: |
|
| 查看次数: |
922 次 |
| 最近记录: |