码迷,mamicode.com
首页 > 其他好文 > 详细

Callable、Future、FutureTask_笔记

时间:2018-03-14 21:10:32      阅读:178      评论:0      收藏:0      [点我收藏+]

标签:设定   异步执行   int   []   running   http   out   实例   net   

参考:http://blog.csdn.net/javazejian/article/details/50896505

1、Callable<V>接口

Runnable接口

public interface Runnable {  
    public abstract void run();  
} 

Callable

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

runnable接口 Callable接口 都可以被ThreadPoolExecutor或ScheduledThreadPoolExecutor执行,两者实现了ExcutorService接口

ExecutorService接口

<T> Future<T> submit(Callable<T> task);  
<T> Future<T> submit(Runnable task, T result);  
Future<?> submit(Runnable task);

2、Future<V> 

获得异步计算结果,说白了就是对具体的Runnable或者Callable对象任务执行的结果进行获取(get()),取消(cancel()),判断是否完成等操作。

public interface Future<V> {  
  //如果任务没开始,cancle()将会返回true
  //如果任务已经启动,执行cancle(true)将以中断执行此任务线程的方式来试图阻止任务,成功返沪true
//如果任务已经启动,执行cancle(false)将不会对执行线程产生影响,此时返回false
boolean cancel(boolean mayInterruptIfRunning);
  //如果任务完成前被取消,返回true
boolean isCancelled();
  //如果任务结束,无论是正常结束或是中途取消还是发生异常,都会true
boolean isDone();
  //获取异步执行结果,如果没有结果可用,此方法会阻塞直到异步计算完成。 V get()
throws InterruptedException, ExecutionException;
  //获取异步执行结果,如果没有结果可用,此方法会阻塞,
//但是会有时间限制,如果阻塞时间超过设定的timeout时间,该方法将抛出异常。 V get(
long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException; }

3、FutureTask类

public class FutureTask<V> implements RunnableFuture<V> {  

其中

public interface RunnableFuture<V> extends Runnable, Future<V> {  
    void run();  
}  

构造方法:

public interface RunnableFuture<V> extends Runnable, Future<V> {  
    void run();  
}  

使用场景:

1、使用Callable+Future获取执行结果

package com.zejian.Executor;  
import java.util.concurrent.Callable;  
/** 
 * @author zejian 
 * @time 2016年3月15日 下午2:02:42 
 * @decrition Callable接口实例 
 */  
public class CallableDemo implements Callable<Integer> {  
      
    private int sum;  
    @Override  
    public Integer call() throws Exception {  
        System.out.println("Callable子线程开始计算啦!");  
        Thread.sleep(2000);  
          
        for(int i=0 ;i<5000;i++){  
            sum=sum+i;  
        }  
        System.out.println("Callable子线程计算结束!");  
        return sum;  
    }  
}  
package com.zejian.Executor;  
import java.util.concurrent.ExecutorService;  
import java.util.concurrent.Executors;  
import java.util.concurrent.Future;  
/** 
 * @author zejian 
 * @time 2016年3月15日 下午2:05:43 
 * @decrition callable执行测试类 
 */  
public class CallableTest {  
      
    public static void main(String[] args) {  
        //创建线程池  
        ExecutorService es = Executors.newSingleThreadExecutor();  
        //创建Callable对象任务  
        CallableDemo calTask=new CallableDemo();  
        //提交任务并获取执行结果  
        Future<Integer> future =es.submit(calTask);  
        //关闭线程池  
        es.shutdown();  
        try {  
            Thread.sleep(2000);  
        System.out.println("主线程在执行其他任务");  
          
        if(future.get()!=null){  
            //输出获取到的结果  
            System.out.println("future.get()-->"+future.get());  
        }else{  
            //输出获取到的结果  
            System.out.println("future.get()未获取到结果");  
        }  
          
        } catch (Exception e) {  
            e.printStackTrace();  
        }  
        System.out.println("主线程在执行完成");  
    }  
} 

执行结果:

Callable子线程开始计算啦!
主线程在执行其他任务
Callable子线程计算结束!
future.get()-->12497500
主线程在在执行完成

2、使用Callable+FutureTask获取执行结果

package com.zejian.Executor;  
import java.util.concurrent.ExecutorService;  
import java.util.concurrent.Executors;  
import java.util.concurrent.Future;  
import java.util.concurrent.FutureTask;  
/** 
 * @author zejian 
 * @time 2016年3月15日 下午2:05:43 
 * @decrition callable执行测试类 
 */  
public class CallableTest {  
      
    public static void main(String[] args) {            
        //创建线程池  
        ExecutorService es = Executors.newSingleThreadExecutor();  
        //创建Callable对象任务  
        CallableDemo calTask=new CallableDemo();  
        //创建FutureTask  
        FutureTask<Integer> futureTask=new FutureTask<>(calTask);  
        //执行任务  
        es.submit(futureTask);  
        //关闭线程池  
        es.shutdown();  
        try {  
            Thread.sleep(2000);  
        System.out.println("主线程在执行其他任务");  
          
        if(futureTask.get()!=null){  
            //输出获取到的结果  
            System.out.println("futureTask.get()-->"+futureTask.get());  
        }else{  
            //输出获取到的结果  
            System.out.println("futureTask.get()未获取到结果");  
        }  
          
        } catch (Exception e) {  
            e.printStackTrace();  
        }  
        System.out.println("主线程在执行完成");  
    }  
}  

结果:

Callable子线程开始计算啦!
主线程在执行其他任务
Callable子线程计算结束!
futureTask.get()-->12497500
主线程在执行完成

 

Callable、Future、FutureTask_笔记

标签:设定   异步执行   int   []   running   http   out   实例   net   

原文地址:https://www.cnblogs.com/L-a-u-r-a/p/8570086.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!