CSDN话题挑战赛第2期
参赛话题:一起学Java
特点:可以得到线程的执行的任务结果
Callable使用步骤:
1》写一个实现callable接口实现类为线程所要执行的任务,
并指定泛型,泛型为任务的执行结果类型
2》创建Callable任务对象,并将该对象封装在Futuretask中
3》创建一个线程来执行Futuretask,并通过该类的get()方法来获取任务执行结果
4》也通过调用线程池的submit()方法来执行任务,
并将任务执行结果封装在Future类中
并通过Future的get()方法来获取任务的执行结果
1》Callable执行任务调用Call()方法,
可以获取任务执行结果,也可以抛出异常
2》Runnable执行任务调用run()方法
不能获取任务执行结果,也不可以抛出异常
- import java.util.concurrent.Callable;
- import java.util.concurrent.ExecutionException;
- import java.util.concurrent.ExecutorService;
- import java.util.concurrent.Executors;
- import java.util.concurrent.Future;
- import java.util.concurrent.FutureTask;
- import java.util.concurrent.TimeUnit;
- import java.util.concurrent.TimeoutException;
-
- /**Callable实现线程*/
- public class ThreadDemo17 {
- public static void main(String[] args)
- throws InterruptedException, ExecutionException, TimeoutException {
- //创建任务对象
- MyCall myCall=new MyCall();
- // FutureTask
task=new FutureTask(myCall); - // Thread t=new Thread(task);
- // t.start();
- // //获取任务的执行结果,该方法为阻塞式的、
- // //获取不到结果就会一直等待
- String result=task.get();
- // //设置超时时间(阻塞时间)
- // //如果指定时间内获取不到结果,就抛出超时异常
- // String result=task.get(3,TimeUnit.SECONDS);
- // System.out.println(result);
-
- ExecutorService es=Executors.newSingleThreadExecutor();
- Future
f=es.submit(myCall); - //获取任务执行结果
- String result=f.get();
- System.out.println(result);
- }
-
- }
- /**
- * 实现Callable接口实现类为线程所要执行的任务
- * 相当于Runable,泛型为任务的执行结果类型
- *
- */
- class MyCall implements Callable
{ -
- @Override
- public String call() throws Exception {
- Thread.sleep(5000);
- return "==返回值==";
- }
-
- }