在周围挖(再一次)
Q1:为什么是死锁?
implicit val ec = ExecutionContext.fromExecutor(Executors.newFixedThreadPool(4))
val futures = List( Future{1} )
val result: Future[List[Int]] = Future.sequence(futures)
Await.ready(result, Duration.Inf)当我在池中有5个未来/线程时,我希望有类似的行为(超过4个)。
发布于 2015-08-20 01:49:10
也许这不是僵局。我认为主线程正在等待线程池退出。尝试调用执行器服务的.shutdown()。
import java.util.concurrent.Executors
import scala.concurrent.duration.Duration
import scala.concurrent.{ExecutionContext, Await, Future}
object DeadLockSample1 {
def main(args: Array[String]) {
val pool = Executors.newFixedThreadPool(4)
implicit val ec = ExecutionContext.fromExecutor(pool)
Future{1}
pool.shutdown() // without this, it won't exit.
}
}https://stackoverflow.com/questions/32107833
复制相似问题