Java多线程之Callable接口的实现

　Java多线程之Callable接口的实现由广州疯狂软件java培训分享：

　　import java.util.concurrent.Callable;

　　import java.util.concurrent.ExecutorService;

　　import java.util.concurrent.Executors;

　　import java.util.concurrent.Future;

　　/** *//**

　　* Callable 和 Future接口

　　* Callable是类似于Runnable的接口，实现Callable接口的类和实现Runnable的类都是可被其它线程执行的任务。

　　* Callable和Runnable有几点不同：

　　* (1)Callable规定的方法是call()，而Runnable规定的方法是run().

　　* (2)Callable的任务执行后可返回值，而Runnable的任务是不能返回值的。

　　* (3)call()方法可抛出异常，而run()方法是不能抛出异常的。

　　* (4)运行Callable任务可拿到一个Future对象，

　　* Future 表示异步计算的结果。它提供了检查计算是否完成的方法，以等待计算的完成，并检索计算的结果。

　　* 通过Future对象可了解任务执行情况，可取消任务的执行，还可获取任务执.M行的结果。

　　*/

　　public class CallableAndFuture {

　　/** *//**

　　* 自定义一个任务类，实现Callable接口

　　*/

　　public static class MyCallableClass implements Callable{

　　// 标志位

　　private int flag = 0;

　　public MyCallableClass(int flag){

　　this.flag = flag;

　　}

　　public String call() throws Exception{

　　if (this.flag == 0){

　　// 如果flag的值为0，则立即返回

　　return "flag = 0";

　　}

　　if (this.flag == 1){

　　// 如果flag的值为1，做一个无限循环

　　try {

　　while (true) {

　　System.out.println("looping.");

　　Thread.sleep(2000);

　　}

　　} catch (InterruptedException e) {

　　System.out.println("Interrupted");

　　}

　　return "false";

　　} else {

　　// falg不为0或者1，则抛出异常

　　throw new Exception("Bad flag value!");

　　}

　　}

　　}

　　public static void main(String[] args) {

　　// 定义3个Callable类型的任务

　　MyCallableClass task1 = new MyCallableClass(0);

　　MyCallableClass task2 = new MyCallableClass(1);

　　MyCallableClass task3 = new MyCallableClass(2);

　　// 创建一个执行任务的服务

　　ExecutorService es = Executors.newFixedThreadPool(3);

　　try {

　　// 提交并执行任务，任务启动时返回了一个 Future对象，

　　// 如果想得到任务执行的结果或者是异常可对这个Future对象进行操作

　　Future future1 = es.submit(task1);

　　// 获得第一个任务的结果，如果调用get方法，当前线程会等待任务执行完毕后才往下执行

　　System.out.println("task1: " + future1.get());

　　Future future2 = es.submit(task2);

　　// 等待5秒后，再停止第二个任务。因为第二个任务进行的是无限循环

　　Thread.sleep(5000);

　　System.out.println("task2 cancel: " + future2.cancel(true));

　　// 获取第三个任务的输出，因为执行第三个任务会引起异常

　　// 所以下面的语句将引起异常的抛出

　　Future future3 = es.submit(task3);

　　System.out.println("task3: " + future3.get());

　　} catch (Exception e){

　　System.out.println(e.toString());

　　}

　　// 停止任务执行服务

　　es.shutdownNow();

　　}

　　}

　　疯狂软件教育中心紧扣IT前沿技术的脉搏，高瞻远瞩立于潮头，引领行业标杆，开创IT教育培训的新天地，被称为新式IT教育的“黄埔军校”。疯狂软件教育中心主要面向大学生和准大学生的长期就业培训、企业员工定制内训、在职工程师的短期高端培训以及企业级应用的产品研发，其专业服务和质量承诺在客户中赢得广泛的声誉。

　　疯狂软件教育中心结合自身特色，打破固有思维模式，以突出实战性，系统性，学识转换相结合的理念体系指引下，注重如何将培训内容真正转化为实操经验，以此促进工作能力的达成。在疯狂软件学院，学员通过参与企业实际项目开发，学以致用，获得实际项目经验。凭借自身强悍的师资、一流的课程、真实的项目、超高的就业率已经让广大南方学子成功走上软件工程师职业道路，大量毕业即失业的学子已通过疯狂软件教育中心实现了就业。