JAVA并发-Callable

大家好，欢迎来到IT知识分享网。

Callable接口,
java.util.concurrent.Callable,代表着可以通过另外的线程异步执行的任务，例如，可以将一个Callable对象提交到ExecutorService异步执行，我们之前讲过java创建启动线程,现在我们又多了一种Callable,我们先看下如果使用，然后再讲述：

 package com.ck.thread;   import java.util.concurrent.Callable; import java.util.concurrent.ExecutionException; import java.util.concurrent.FutureTask;   public class TestCallable implements Callable<String>{       @Override     public String call() throws Exception {         System.out.println("callable 方式");         return "yes";     }       public static void main(String[] args) {         TestCallable callable = new TestCallable();         FutureTask<String> task = new FutureTask<String>(callable);         Thread thread = new Thread(task);         thread.start();         try {             System.out.println(task.get());         } catch (InterruptedException e) {             e.printStackTrace();         } catch (ExecutionException e) {             e.printStackTrace();         }     } }

执行结果：

callable 方式 yes

下面我们再详细讲述：

Callable接口定义

Callable接口非常简单 ，包含了一个简单的方法call()，下面是Callable接口：

public interface Callable<V> {       V call() throws Exception;   }

调用 call()方法是为了异步执行任务， call()可以返回结果，结果通常通过Future返回给任务的创建者，这就是将Callable 提交给ExecutorService并发执行，在执行中如果任务执行失败将会抛Exception 。

实现 Callable

下面是实现了 Callable 接口:

public class MyCallable implements Callable<String> {       @Override     public String call() throws Exception {         return String.valueOf(System.currentTimeMillis());     } }

实现非常简单，用的泛型是String,call()方法的返回结果将是String, call()方法的实现只是简单的返回了当前时间用秒数表示，在实际应用中，任务可能更复杂，更大，更多的操作。

常见的，从磁盘或者网络中读写数据的IO操作，是可以同时执行的任务的最佳候选对象，IO操作在读写数据时通常需要阻塞很长时间，通过在单独的线程中执行这些任务，可以避免不必要地阻塞主应用程序线程。

Callable 和Runnable

这个我们在前一篇文章也讲过，Runnable 和Callable非常相似，都代表了一个线程或者ExecutorSerivce可以并发放执行的任务，两个接口都只有一个方法，两者只有一个细小的差别，他们之间的区别可以通过接口定义看出来.

Runnable接口:

public interface Runnable {     public void run(); }

Callable 接口:

public interface Callable{     public Object call() throws Exception; }

主要区别是 Runnable run() 和Callable call()，call() 可以返回 Object，另外不同是 call()可以 throw 一个 exception, run()却不能 (除了不受检查的RuntimeException以及其子类).

如果需要通过ExecutorService 提交任务并且能有返回的结果，那么需要实现Callable 接口，否则值只要实现Runnable 接口。

参考：
http://tutorials.jenkov.com/java-util-concurrent/java-callable.html

https://blog.csdn.net/cgsyck/article/details/

https://blog.csdn.net/cgsyck/article/details/