用Scala寫Java執行緒池
阿新 • • 發佈:2018-12-18
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()) } } }