毫无疑问 runnable会进行异步执行,此处不多数,主要说明callable的使用,看实例:
1、
public class threadtest {
public static void main(string[] args) throws interruptedexception, executionexception {
executorservice executor = executors.newfixedthreadpool(4);
mytread m1 = new mytread();
future f = executor.submit(m1);
// system.out.println(f.get());
executor.shutdown();
system.out.println("主线程执行完了");
}
}
class mytread implements callable<string> {
@override
public string call() {
try {
system.out.println("线程调度:" + thread.currentthread());
timeunit.seconds.sleep(3);
} catch (interruptedexception e) {
e.printstacktrace();
}
return "123";
此程序虽然获取了call方法的返回值,但是没有做处理,所以主线程main和m1同时执行,执行结果如下:
主线程执行完了
线程调度:thread[pool-1-thread-1,5,main]
2、
system.out.println(f.get()); // 进行了输出
在2中,对m1中call方法的返回值在main中进行了处理(输出),所以在此种情况下,main需要等待m1执行完,再继续执行,执行结果如下
123
3、再看当主线程中同时启动两个由callable生成的线程时
mytread2 m2 = new mytread2();
long time1 = timeunit.milliseconds.toseconds(system.currenttimemillis());
future f2 = executor.submit(m2);
system.out.println(f.get()); // 进行了输出m1
system.out.println(f2.get()); // 进行了输出m2
long time2 = timeunit.milliseconds.toseconds(system.currenttimemillis());
system.out.println("主线程等待了" + (time2 - time1) + "秒");
class mytread2 implements callable<string> {
system.out.println("线程调度2:" + thread.currentthread());
return "abc";
当不对m1和m2做输出时,main和m1、m2并发执行,当对m1和m2中任意一个的返回值进行处理的时候,main需要等待,但是m1和m2之前仍然是并发执行,执行结果如下:
线程调度2:thread[pool-1-thread-2,5,main]
abc
主线程等待了3秒
特别说明:尊重作者的劳动成果,转载请注明出处哦~~~http://blog.yemou.net/article/query/info/tytfjhfascvhzxcyt125