首页 > 代码库 > 初学scala3——使用future实现并发
初学scala3——使用future实现并发
future可以实现多线程并发,使用起来简单,但是效果很好,直接看代码吧
import java.text.SimpleDateFormat import java.util.Date import java.util.concurrent.TimeUnit import scala.concurrent.{Await, Future} import scala.concurrent.ExecutionContext.Implicits.global import scala.concurrent.duration._ object FutureTest { def main(args: Array[String]): Unit = { val results = Await.result(f4, 5 seconds) println("end: " + new SimpleDateFormat("hh:mm:ss:SSS").format(new Date())) println(results) } val f1 = Future { println("f1 executing " + new SimpleDateFormat("hh:mm:ss:SSS").format(new Date())) TimeUnit.SECONDS.sleep(1) "f1" } val f2 = Future { println("f2 executing " + new SimpleDateFormat("hh:mm:ss:SSS").format(new Date())) TimeUnit.SECONDS.sleep(2) "f2" } val f3 = Future { println("f3 executing " + new SimpleDateFormat("hh:mm:ss:SSS").format(new Date())) TimeUnit.SECONDS.sleep(3) "f3" } val f4: Future[Seq[String]] = Future.sequence(Seq(f1, f2, f3)) }
结果如下:
f1 executing 10:57:10:741 f3 executing 10:57:10:741 f2 executing 10:57:10:788 end: 10:57:13:760 List(f1, f2, f3)
f1、f2、f3同时启动,说明实现了多线程并发
初学scala3——使用future实现并发
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。