携带结果的任务Callable和Future

    Executor框架使用Runnable作为基本的任务表示形式，但是Runnable有一定的局限性：不能返回一个值或抛出一个受检查的异常。实际中很多任务都是存在延迟的，如执行数据库查询、从网络上获取资源或执行复杂计算先进，对于这样的任务，Callable是一种更好的抽象：它认为入口(call)将返回一个值并并可能抛出一个异常。

Callable

    定义：

package java.util.concurrent;
public interface Callable<V> {
    V call() throws Exception;
}

    返回结果并且可能抛出异常的任务。实现者定义了一个不带任何参数的叫做 call 的方法。 Callable 接口类似于 Runnable，两者都是为那些其实例可能被另一个线程执行的类设计的。但是 Runnable 不会返回结果，并且无法抛出经过检查的异常。

Future

表示一个任务的生命周期，并提供了相应的方法来判断是否已经完成或取法一个任务，以及获取任务的结果和取消任务等。

定义：

package java.util.concurrent;
public interface Future<V> {
    boolean cancel(boolean mayInterruptIfRunning);
    boolean isCancelled();
    boolean isDone();
    V get() throws InterruptedException, ExecutionException;
    V get(long timeout, TimeUnit unit)
        throws InterruptedException, ExecutionException, TimeoutException;
}

 Future 表示异步计算的结果。它提供了检查计算是否完成的方法，以等待计算的完成，并获取计算的结果。计算完成后只能使用 get 方法来获取结果，如有必要，计算完成前可以阻塞此方法。取消则由 cancel 方法来执行。还提供了其他方法，以确定任务是正常完成还是被取消了。一旦计算完成，就不能再取消计算。如果为了可取消性而使用 Future 但又不提供可用的结果，则可以声明 Future<?> 形式类型、并返回 null 作为底层任务的结果。

 

方法摘要：

 boolean cancel(boolean mayInterruptIfRunning) 
          试图取消对此任务的执行。 
 V get() 
          如有必要，等待计算完成，然后获取其结果。 
 V get(long timeout, TimeUnit unit) 
          如有必要，最多等待为使计算完成所给定的时间之后，获取其结果（如果结果可用）。 
 boolean isCancelled() 
          如果在任务正常完成前将其取消，则返回 true。 
 boolean isDone() 
          如果任务已完成，则返回 true。 

 

如下代码：

package thread;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
public class FutureTest {
	public static void main(String[] args) {
		System.out.println("call start.");
		System.out.println("call:" + FutureApp.showSearch("callable......"));
		System.out.println("call finished.");
	}
}
class FutureApp {
	static ExecutorService	executor	= Executors.newFixedThreadPool(5);
	
	public static String showSearch(final String target) {
		try {
			Future<String> future = executor.submit(new Callable<String>() {
				public String call() {
					return "callable result";
				}
			});
                        executor.shutdown();
			Thread.sleep(2000); // do other things while searching
			return future.get(); // use future
		}
		catch (Exception ex) {
			return "";
		}
	}
}

call start.
call:callable result
call finished.