天天看点

java 多线程Callable和Runable执行顺序问题详解

毫无疑问 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