scala线程demo-callable

object CallableThread {

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

val threads = Executors.newCachedThreadPool

val f1 = new FutureTask[String](new Callable[String] {

override def call(): String = {

Thread.sleep(10)

"fuck you - 1"

}

})

val f2 = new FutureTask[String](new Callable[String] {

override def call(): String = {

Thread.sleep(10)

"fuck you - 2"

}

})

threads.execute(f1)

threads.execute(f2)

println(f1.get)

println(f2.get)

Thread.sleep(3000)

threads.shutdown

}

}