java多线程 Callable 的实现_JAVA

您所在的位置：程序员俱乐部 > 编程开发 > JAVA > java多线程 Callable 的实现

java多线程 Callable 的实现

2011/9/21 8:10:34 haya http://haya.iteye.com 我要评论(0)

摘要：importjava.util.concurrent.Callable;importjava.util.concurrent.ExecutorService;importjava.util.concurrent.Executors;importjava.util.concurrent.Future;/***//***Callable和Future接口*Callable是类似于Runnable的接口，实现Callable接口的类和实现Runnable的类都是可被其它线程执行的任务
标签：实现多线程 all 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对象可了解任务执行情况，可取消任务的执行，还可获取任务执行的结果。?? ?
?*/ ?? ??
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();??? ??
????}??? ??
}??