Java多线程---从线程中返回数据
一.通过类变量和方法返回数
如下:
public class MyThread extends Thread { private String value; public void run() { value = "通过成员变量返回数据"; } public static void main(String[] args) throws Exception { MyThread thread = new MyThread(); thread.start(); System.out.println("value:" + thread.value); } }但是运行上边代码基本不是你预期得到的结果,可能为
value:null
虽然在run方法中已经对value赋了值,而返回的却是null。发生这种情况的原因是调用
start方法后就立刻输出了value的值,而这里run方法还没有执行到为value赋值的语
句。 为了避免这种情况的发生,就需要等run方法执行完后才执行输出value的值。因此,我
们可以使用sleep方法将主线程进行延迟,如可以在thread.start()后加如下的语句:
sleep(1000);//等待一秒
这样做可以使主线程延迟1秒后再往下执行,但是对于这里来说太久了(有时可能
又太少,所以还要判断value是否为空)
虽然这样可以解决,但Java的线程模型为我们提供了更好的解决方案,这就是join
方法。
join的功能就是使用线程从异步执行变成同步执行。当线程变成同步执行后,就和
从普通的方法中得到返回数据没有什么区别了。如下语句
thread.start();
thread.join();
在thread.join()执行完后,线程thread的run方法已经退出了,也就是说线程thread已
经结束了。
注:join还有方法为thread.join(mills);最多等待时间,如果这个时间到了还没执行
完,下边代码也将继续执行。 三.Java5新增了Callable接口获得线程的返回值
实现Callable接口
import java.util.concurrent.Callable; public class MyThread2 implements Callable<String> { @Override public String call() throws Exception { String string="通过实现Callable借口返回"; return string; } }
这样调用
public static void main(String[] args) { ExecutorService executorService=Executors.newCachedThreadPool(); Callable<String> callable=new MyThread2(); Future future=executorService.submit(callable); try { if(future.isDone()){ System.out.println(future.get()); } } catch (Exception e) { e.printStackTrace(); } }
必须使用ExecutorService的submit方法来执行,返回一个Future对象
可以使用isDone()方法检测future是否完成,完成后可以调用get()方法获得future的
值, 如果直接调用get()方法,get()方法将阻塞值线程结束
(还有以下方法可以使用)
三.通过回调函数返回数据