java多线程 Callable 的兑现

java多线程 Callable 的实现

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对象可了解任务执行情况，可取消任务的执行，还可获取任务执行的结果。?? ??*/?? ??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();??? ??????}??? ??}??