栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

Java 获取多线程返回值的几种方式

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

Java 获取多线程返回值的几种方式

第一种:使用Callable加上FutureTask来实现

public static void main(String[] args) throws ExecutionException, InterruptedException {
        FutureTask futureTask=new FutureTask(new TestA());
        Thread thread=new Thread(futureTask);
        thread.start();
        Integer integer = futureTask.get();
        System.out.println(integer);
    }

    static class TestA implements Callable{

        @Override
        public Integer call() throws Exception {
            Thread.sleep(1000);
            return 1;
        }
    }
 

Callable的call方法已经规定线程的返回值了,很好理解
第二种:主线程等待,直到子线程执行完成

public static void main(String[] args) throws InterruptedException {
        ThreadTest threadTest=new ThreadTest();
        threadTest.start();
        while (threadTest.a==null){
            Thread.sleep(100);
        }
        System.out.println(threadTest.a);
    }

    static class ThreadTest extends Thread{
        Integer a;
        @Override
        public void run() {
            super.run();
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            a=1;
        }
    }

第三种:与第二种类似采用Thread的join方法,主线程会等调用了join的子线程执行完后再执行

public static void main(String[] args) throws InterruptedException {
        ThreadTest threadTest=new ThreadTest();
        threadTest.start();
        threadTest.join();
        System.out.println(threadTest.a);
    }
    static class ThreadTest extends Thread{
        Integer a;
        @Override
        public void run() {
            super.run();
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            a=1;
        }
    }

第四种:使用CountDownLatch,CountDownLatch的await方法表示等待,countDown方法表示等待线程数减一,当等待线程数为0时,开始向下执行

public static void main(String[] args) throws InterruptedException {
        CountDownLatch countDownLatch=new CountDownLatch(1);
        ThreadTest02 threadTest02=new ThreadTest02(countDownLatch);
        threadTest02.start();
        countDownLatch.await();
        System.out.println(threadTest02.a);
    }
   static class ThreadTest02 extends Thread{

        private CountDownLatch countDownLatch;
        private int a;
        public ThreadTest02(CountDownLatch countDownLatch){
            this.countDownLatch=countDownLatch;
        }

       @Override
       public void run() {
           super.run();
           try {
               Thread.sleep(1000);
               a=1;
           } catch (InterruptedException e) {
               e.printStackTrace();
           }
           countDownLatch.countDown();
       }
   }
转载请注明:文章转载自 www.mshxw.com
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号