这篇文章将为大家详细讲解有关scala中如何使用多线程,文章内容质量较高,因此小编分享给大家做个参考,希望大家阅读完这篇文章后对相关知识有一定的了解。
写的一个scala多线程的小demo,以备后用
Runnable/Callable
区别:Runnable无返回值,Callable线程执行完有返回值
Runnable示例
import java.util.concurrent.{Executors, ExecutorService}
object Test {
def main(args: Array[String]) {
//创建线程池
val threadPool:ExecutorService=Executors.newFixedThreadPool(5)
try {
//提交5个线程
for(i <- 1 to 5){
//threadPool.submit(new ThreadDemo("thread"+i))
threadPool.execute(new ThreadDemo("thread"+i))
}
}finally {
threadPool.shutdown()
}
}
//定义线程类,每打印一次睡眠100毫秒
class ThreadDemo(threadName:String) extends Runnable{
override def run(){
for(i <- 1 to 10){
println(threadName+"|"+i)
Thread.sleep(100)
}
}
}
}
Callable示例
import java.util.concurrent.{Callable, FutureTask, Executors, ExecutorService}
object Test {
def main(args: Array[String]) {
val threadPool:ExecutorService=Executors.newFixedThreadPool(3)
try {
val future=new FutureTask[String](new Callable[String] {
override def call(): String = {
Thread.sleep(100)
return "im result"
}
})
threadPool.execute(future)
println(future.get())
}finally {
threadPool.shutdown()
}
}
}
关于scala中如何使用多线程就分享到这里了,希望以上内容可以对大家有一定的帮助,可以学到更多知识。如果觉得文章不错,可以把它分享出去让更多的人看到。
亿速云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。
原文链接:https://my.oschina.net/u/877759/blog/501733