zoukankan      html  css  js  c++  java
  • Callable和Future

    Callable和Future

    概述
    • Callable和Future,它俩很有意思的,一个产生结果,一个拿到结果。

    • Future表示一个可能还没有完成的异步任务的结果,针对这个结果可以添加Callback以便在任务执行成功或失败后作出相应的操作。

    • Callable接口中只有一个call()方法,和Runnable相比,该方法有返回值并允许抛出异常

    • FutureTask是Runnable, Future接口的实现类。

    • RunnableFuture

      • 这个接口同时继承Future接口和Runnable接口,在成功执行run()方法后,可以通过Future访问执行结果。这个接口都实现类是FutureTask,一个可取消的异步计算,这个类提供了Future的基本实现,后面我们的demo也是用这个类实现,它实现了启动和取消一个计算,查询这个计算是否已完成,恢复计算结果。计算的结果只能在计算已经完成的情况下恢复。如果计算没有完成,get方法会阻塞,一旦计算完成,这个计算将不能被重启和取消,除非调用runAndReset方法。
      • FutureTask能用来包装一个Callable或Runnable对象,因为它实现了Runnable接口,而且它能被传递到Executor进行执行。为了提供单例类,这个类在创建自定义的工作类时提供了protected构造函数。
    • enter image description here

    Future的主要方法
    • get()方法可以当任务结束后返回一个结果,如果调用时,工作还没有结束,则会阻塞线程,直到任务执行完毕get(long timeout,TimeUnit unit)做多等待timeout的时间就会返回结果
    • cancel(boolean mayInterruptIfRunning)方法可以用来停止一个任务,如果任务可以停止(通过mayInterruptIfRunning来进行判断),则可以返回true,如果任务已经完成或者已经停止,或者这个任务无法停止,则会返回false.
    • isDone()方法判断当前方法是否完成
    • isCancel()方法判断当前方法是否取消
    示例
    • 普通线程模式
    public class BumThread extends Thread{
    	
    	@Override
    	public void run() {
    		try {
    			Thread.sleep(1000*3);
    			System.out.println("包子准备完毕");
    		} catch (InterruptedException e) {
    			e.printStackTrace();
    		}
    	}
     
    }
    
    public class ColdDishThread extends Thread{
    	
    	@Override
    	public void run() {
    		try {
    			Thread.sleep(1000);
    			System.out.println("凉菜准备完毕");
    		} catch (InterruptedException e) {
    			e.printStackTrace();
    		}
    	}
     
    }
    
    public static void main(String[] args) throws InterruptedException {
    		long start = System.currentTimeMillis();
    		
    		// 等凉菜 -- 必须要等待返回的结果,所以要调用join方法
    		Thread t1 = new ColdDishThread();
    		t1.start();
    		t1.join();
    		
    		// 等包子 -- 必须要等待返回的结果,所以要调用join方法
    		Thread t2 = new BumThread();
    		t2.start();
    		t2.join();
    		
    		long end = System.currentTimeMillis();
    		System.out.println("准备完毕时间:"+(end-start));
    }
    
    
    • Future模式
    public static void main(String[] args) throws InterruptedException, ExecutionException {
    		long start = System.currentTimeMillis();
    		
    		// 等凉菜 
    		Callable ca1 = new Callable(){
     
    			@Override
    			public String call() throws Exception {
    				try {
    					Thread.sleep(1000);
    				} catch (InterruptedException e) {
    					e.printStackTrace();
    				}
    				return "凉菜准备完毕";
    			}
    		};
    		FutureTask<String> ft1 = new FutureTask<String>(ca1);
    		new Thread(ft1).start();
    		
    		// 等包子 -- 必须要等待返回的结果,所以要调用join方法
    		Callable ca2 = new Callable(){
     
    				@Override
    				public Object call() throws Exception {
    					try {
    						Thread.sleep(1000*3);
    					} catch (InterruptedException e) {
    						e.printStackTrace();
    					}
    					return "包子准备完毕";
    			}
    		};
    		FutureTask<String> ft2 = new FutureTask<String>(ca2);
    		new Thread(ft2).start();
    		
    		System.out.println(ft1.get());
    		System.out.println(ft2.get());
    		
    		long end = System.currentTimeMillis();
    		System.out.println("准备完毕时间:"+(end-start));
    }
    
  • 相关阅读:
    CF-1111 (2019/2/7 补)
    CF-1096C Polygon for the Angle
    CF-1100 E Andrew and Taxi
    CF-1099 D. Sum in the tree
    sscanf的使用
    CF-1082(渣渣只做了前三个)
    UVA-10817- Headmaster's Headache(状压DP)
    UVA-1220-Party at Hali-Bula && UVA-1218-Perfect Service(树形DP)
    CF-1072-C. Cram Time(贪心,数学)
    CF-1027-B. Curiosity Has No Limits
  • 原文地址:https://www.cnblogs.com/frankltf/p/10554932.html
Copyright © 2011-2022 走看看