Java Callable Future 示例

在多线程编程中，Java的Callable和Future被广泛使用。在最近的几篇文章中，我们学习到了很多关于Java线程的知识，但有时我们希望线程能够返回一些我们可以使用的值。Java 5引入了并发包中的java.util.concurrent.Callable接口，它类似于Runnable接口，但它可以返回任意对象并且能够抛出异常。

Java可调用的

Java的Callable接口使用泛型来定义返回的Object的类型。Executors类提供了在线程池中执行Java Callable的有用方法。由于可调用任务是并行运行的，所以我们必须等待返回的Object。

Java 未来

Java的Callable任务返回java.util.concurrent.Future对象。使用Java Future对象，我们可以了解Callable任务的状态并获取返回的对象。它提供了get()方法，可以等待Callable任务完成，然后返回结果。Java Future提供了cancel()方法来取消关联的Callable任务。get()方法有一个重载版本，我们可以指定等待结果的时间，这对于避免当前线程长时间被阻塞很有用。还有isDone()和isCancelled()方法，用于了解关联的Callable任务的当前状态。这是一个简单的Java Callable任务的例子，在一秒钟后返回执行任务的线程名称。我们使用Executor框架并行执行100个任务，并使用Java Future获取提交任务的结果。

package com.Olivia.threads;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

public class MyCallable implements Callable<String> {

    @Override
    public String call() throws Exception {
        Thread.sleep(1000);
        //return the thread name executing this callable task
        return Thread.currentThread().getName();
    }
    
    public static void main(String args[]){
        //Get ExecutorService from Executors utility class, thread pool size is 10
        ExecutorService executor = Executors.newFixedThreadPool(10);
        //create a list to hold the Future object associated with Callable
        List<Future<String>> list = new ArrayList<Future<String>>();
        //Create MyCallable instance
        Callable<String> callable = new MyCallable();
        for(int i=0; i< 100; i++){
            //submit Callable tasks to be executed by thread pool
            Future<String> future = executor.submit(callable);
            //add Future to the list, we can get return value using Future
            list.add(future);
        }
        for(Future<String> fut : list){
            try {
                //print the return value of Future, notice the output delay in console
                // because Future.get() waits for task to get completed
                System.out.println(new Date()+ "::"+fut.get());
            } catch (InterruptedException | ExecutionException e) {
                e.printStackTrace();
            }
        }
        //shut down the executor service now
        executor.shutdown();
    }

}

当我们执行上述程序时，你会注意到输出有延迟，因为Java的Future get()方法会等待Java Callable任务完成。同时还要注意，只有10个线程在执行这些任务。以下是上述程序的一部分输出。

Mon Dec 31 20:40:15 PST 2012::pool-1-thread-1
Mon Dec 31 20:40:16 PST 2012::pool-1-thread-2
Mon Dec 31 20:40:16 PST 2012::pool-1-thread-3
Mon Dec 31 20:40:16 PST 2012::pool-1-thread-4
Mon Dec 31 20:40:16 PST 2012::pool-1-thread-5
Mon Dec 31 20:40:16 PST 2012::pool-1-thread-6
Mon Dec 31 20:40:16 PST 2012::pool-1-thread-7
Mon Dec 31 20:40:16 PST 2012::pool-1-thread-8
Mon Dec 31 20:40:16 PST 2012::pool-1-thread-9
Mon Dec 31 20:40:16 PST 2012::pool-1-thread-10
Mon Dec 31 20:40:16 PST 2012::pool-1-thread-2
...

提示：如果我们想要覆盖Java Future接口的某些方法，例如将get()方法覆盖为在一段默认时间后超时而不是无限等待，这种情况下Java FutureTask类非常方便，它是Future接口的基本实现。查看Java FutureTask示例以了解更多关于这个类的信息。