pool16.scala

val ae = IO.effectAsync[Any, Throwable, Unit] { cb =>
  ec3.submit(new Runnable {
    override def run(): Unit = {
      println(Thread.currentThread().getName + " (async)")
      cb(IO.fail(new IllegalStateException()))
    }
  })
}

run("async shift error") {
  ae.ensuring(printThread.either)
}

/*
Outputs:

-- async shift error --
ec3-1-1627960023 (async)
zio-default-async-11-853993923
*/