基础篇:获取线程返回值与守护线程的创建(二)

有时候，我们可能有 需要拿到线程执行完毕的返回值的需求，这时我们可用通过java.util.concurrent.Future类与Callable接口来完成，如下所示：

//必须实现Callable接口
class MyCallable implements Callable<String>{
private static int count = 0;
private final int id = count++;

@Override
public String call() throws Exception {
//休眠1秒
TimeUnit.MILLISECONDS.sleep(1000);
return "#id"+id+"#";
}
}

//获取返回值，使用submit执行实现了Callable接口的任务
public static void future() throws InterruptedException, ExecutionException{
ExecutorService executor = Executors.newCachedThreadPool();
for (int i = 0; i < 5; i++) {

Future<String> f = executor.submit(new MyCallable());
System.out.println("*******准备获取返回值*******");
//直接调用get()会阻塞，直到任务计算完成；这可以确保我们能拿到返回值
System.out.println(f.get());

}

executor.shutdown();
}

最终，我们调用future()方法会打印以下内容：

输出****************************************************************************

*******准备获取返回值*******

#id0#

*******准备获取返回值*******

#id1#

*******准备获取返回值*******

#id2#

*******准备获取返回值*******

#id3#

*******准备获取返回值*******

#id4#

********************************************************************************
如代码中所示，调用线程池的submit方法将返回一个Future对象，该方法的参数需要传递一个实现了Callable接口的引用，Future对象封装了线程的执行返回结果，它除了get()方法拿到返回值外，还包括了一些其它的方法，具体可以自行查阅JDK的API；

通过观察控制台打印内容，我们看到确实如我们所说，调用future.get()方法将造成阻塞，直到任务计算完成，阻塞自动消除，从而使我们拿到返回结果打印出返回值；

接下来我们看看java的守护线程的创建；

class Daemon implements Runnable{

private static int count = 0;
private final int id = ++count;
@Override
public void run() {
while(true){
try {
TimeUnit.MILLISECONDS.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("守护线程Daemon"+id+"运行完毕");
}
}
}

//守护线程的测试
//当所有线程运行完毕，守护线程将停止运行
public static void daemon() throws InterruptedException{
for (int i = 0; i < 3; i++) {
Thread t = new Thread(new Daemon());
//设置为守护线程
t.setDaemon(true);
t.start();
}
//当5秒过后，主线程运行完毕，我们将看到所有的守护线程将停止运行！
TimeUnit.MILLISECONDS.sleep(3000);
}

守护线程的创建很简单，只需要调用一个正常线程的 setDaemon()方法并设置为true即可，需要注意的是，尽管我们在Daemon类的run方法中设置了无限循环，但它还是会随着主线程的终结而立马终结，这是有意义的，试想，整个程序都运行完毕了，还要守护个啥？

看看输出结果：

************************************************************************************

守护线程Daemon3运行完毕

守护线程Daemon1运行完毕

守护线程Daemon2运行完毕

守护线程Daemon3运行完毕

守护线程Daemon2运行完毕

守护线程Daemon1运行完毕

守护线程Daemon2运行完毕

守护线程Daemon1运行完毕

守护线程Daemon3运行完毕

************************************************************************************

如果采用线程池来运行线程，我们也可以将线程池内的线程指定为守护线程，如下所示：

public static void daemonByFactory() throws InterruptedException{
//可以传入一个ThreadFactory来自定义生成一个线程
ExecutorService exec = Executors.newCachedThreadPool(new ThreadFactory() {
@Override
public Thread newThread(Runnable r) {
Thread thread = new Thread(r);
thread.setDaemon(true);
return thread;
}
});

//启动线程运行
for (int i = 0; i < 3; i++) {
exec.execute(new Daemon());
}

TimeUnit.MILLISECONDS.sleep(3000);
}

在调用Executors.newCachedThreadPool()时，我们可以传入一个ThreadFactory对象，当线程池在内部去创建线程时，它将调用ThreadFactory的newThread方法来创建线程，在newThread方法中，我们执行了Thread.setDaemon(true)，于是乎线程池内的所有线程都将变成守护线程；