码迷,mamicode.com
首页 > 编程语言 > 详细

如何实现处理线程的返回值

时间:2019-12-28 20:43:56      阅读:92      评论:0      收藏:0      [点我收藏+]

标签:如何   mic   nal   wait   ack   val   bsp   future   nbsp   

方法有以下几种:

主线程等待法

使用Thread类的join()阻塞当前线程以等待子线程处理完毕

通过Callable接口实现: 通过FutureTask Or线程池获取

 

一、主线程等待法

如下代码

public class CycleWait implements  Runnable {

    private String name;

    @Override
    public void run() {
        try {
            Thread.sleep(5000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        name = "zhang san";
    }

    public static void main(String[] args) {
        CycleWait cw = new CycleWait();
        Thread t = new Thread(cw);
        t.start();
        System.out.println("name: " + cw.name);
    }
}

  打印的结果为

技术图片

 

 

将它改造成主线程等待法

public class CycleWait implements  Runnable {

    private String name;

    @Override
    public void run() {
        try {
            Thread.sleep(5000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        name = "zhang san";
    }

    public static void main(String[] args) throws InterruptedException {
        CycleWait cw = new CycleWait();
        Thread t = new Thread(cw);
        t.start();
        while (cw.name == null){
            Thread.sleep(100);
        }
        System.out.println("name: " + cw.name);
    }
}

  这样,5秒后就能打印name的值

技术图片

 

二、使用Thread类的join()阻塞当前线程以等待子线程处理完毕

修改上上面的方法

技术图片

 

 

三、通过Callable接口实现: 通过FutureTask Or线程池获取

1、通过FutureTask 

创建MyCallback 类,实现Callable接口

public class MyCallback implements Callable<String>{

    @Override
    public String call() throws Exception {
        String value = "nick";
        System.out.println("Read to work");
        Thread.sleep(5000);
        System.out.println("task done");
        return value;
    }
}

  使用FutureTask的方式

public class FutureTaskDemo {

    public static void main(String[] args) throws ExecutionException, InterruptedException {
        FutureTask<String> task = new FutureTask<String>(new MyCallback());
        new Thread(task).start();

        if(!task.isDone()){
            System.out.println("任务没有完成,请等待");
        }
        System.out.println("任务返回:" + task.get());

    }

}

  打印结果

任务没有完成,请等待
Read to work
task done
任务返回:nick

  

2、使用线程池的方式

public class SomeCallable {

    public static void main(String[] args)  {
        Callable<String> callbale = new Callable<String>() {
            @Override
            public String call() throws Exception {
                Thread.sleep(2000);
                return "ok";
            }
        };

        ExecutorService executorService = Executors.newFixedThreadPool(2);
        //执行任务并获取Future对象
        Future<String> future = executorService.submit(callbale);

        try {
            String result =  future.get();
            System.out.println("result:" + result);
        }catch (Exception e){}
        finally {
            //关闭线程池
            executorService.shutdown();
        }
      
      


    }
}

  

 

如何实现处理线程的返回值

标签:如何   mic   nal   wait   ack   val   bsp   future   nbsp   

原文地址:https://www.cnblogs.com/linlf03/p/12112790.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!