1. 程式人生 > >用Scala寫Java執行緒池

用Scala寫Java執行緒池



import java.util.concurrent.{Callable, Executors, Future}



/**
  * Created by 57871 on 2018/10/31.
  */
object java_Thread {

  def main(args: Array[String]): Unit = {

    val pool = Executors.newFixedThreadPool(5)

    val f :Future[Int] = pool.submit(new Callable[Int] {
      override def call(): Int = {
        Thread.sleep(1000)
        100
      }
    })

    var status = f.isDone
    println(s"status $status")


    Thread.sleep(1500)
    status = f.isDone
    println(s"status $status")

    if(status){
      println(f.get())
    }
  }
}