zoukankan      html  css  js  c++  java
  • ExecutorService的invokeAny方法

    一、此方法获得最先完成任务的结果,即Callable<T>接口中的call的返回值,在获得结果时,会中断其他正在执行的任务

    示例代码:

    import java.util.ArrayList;
    import java.util.List;
    import java.util.concurrent.Callable;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.TimeoutException;
    
    public class MyinvokeAny {
    
    	public static void main(String[] args) {
    		// TODO 自动生成的方法存根
    		List<Callable<String>> list=new ArrayList<Callable<String>>();
    		list.add(new MyCallable_iAny1());
    		list.add(new MyCallable_iAny2());
    		ExecutorService executor=Executors.newCachedThreadPool();
    		
    		try {
    			String str=executor.invokeAny(list);//取出第一个执行完的任务时,其他未完成的任务会被中断
    			System.out.println(str);
    		} catch (InterruptedException e) {
    			// TODO 自动生成的 catch 块
    			e.printStackTrace();
    		} catch (ExecutionException e) {
    			// TODO 自动生成的 catch 块
    			e.printStackTrace();
    		}
    		
    		
    	}
    
    }
    class MyCallable_iAny1 implements Callable<String>{
    
    	@Override
    	public String call() throws Exception {
    		// TODO 自动生成的方法存根
    		try{
    			for(int i=0;i<123456;i++){
    				for(int j=0;j<123;j++){
    					if(Thread.currentThread().isInterrupted()){
    						System.out.println("this is a exception");
    						throw new InterruptedException("A InterruptedException");
    					}
    				}
    			}
    		}catch(Exception e){
    			e.printStackTrace();
    			throw e;
    		}
    		
    		System.out.println("finish");
    		return "call_1";
    	}
    	
    }
    class MyCallable_iAny2 implements Callable<String>{
    
    	@Override
    	public String call() throws Exception {
    		// TODO 自动生成的方法存根
    		Thread.sleep(1000);
    		return "call_2";
    	}
    	
    }
    

      运行结果:

    call_2java.lang.InterruptedException: A InterruptedException
    
    this is a exception
    	at myexecutorservice.MyCallable_iAny1.call(myinvokeAny.java:53)
    	at myexecutorservice.MyCallable_iAny1.call(myinvokeAny.java:1)
    	at java.util.concurrent.FutureTask.run(Unknown Source)
    

      

    二、异常的处理

    对于会先完成,但会出现异常的任务,ExecutorService会将关注点换到下一个任务,若果所有的任务都出现异常,那么将会只获得最后一个任务的异常(例如,有3个任务A,B,C,这三个任务都会出现异常,但是只会获得C任务的异常)

    示例代码:

    import java.util.ArrayList;
    import java.util.List;
    import java.util.concurrent.Callable;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.TimeoutException;
    
    public class myinvokeAny {
    
    	public static void main(String[] args) {
    		// TODO 自动生成的方法存根
    		List<Callable<String>> list=new ArrayList<Callable<String>>();
    		list.add(new MyCallable_iAny1());
    		list.add(new MyCallable_iAny2());
    		ExecutorService executor=Executors.newCachedThreadPool();
    		
    		try {
    			String str=executor.invokeAny(list);//取出第一个执行完的任务时,其他未完成的任务会被中断
    
    			System.out.println(str);
    		} catch (InterruptedException e) {
    			// TODO 自动生成的 catch 块
    			e.printStackTrace();
    		} catch (ExecutionException e) {
    			// TODO 自动生成的 catch 块
    			e.printStackTrace();
    		}
    		
    		
    	}
    
    }
    class MyCallable_iAny1 implements Callable<String>{
    
    	@Override
    	public String call() throws Exception {
    		// TODO 自动生成的方法存根
    		Thread.sleep(2000);
    		
    		System.out.println("finish");
    		return "call_1";
    	}
    	
    }
    class MyCallable_iAny2 implements Callable<String>{
    
    	@Override
    	public String call() throws Exception {
    		// TODO 自动生成的方法存根
    		Thread.sleep(1000);
    		if(true){
    			throw new Exception("myException_B");
    		}
    		return "call_2";
    	}
    	
    }
    

      运行结果:

    finish
    call_1
    

      由此,我们可以看出,MyCallable_iAny2任务出现异常,从而将任务的关注点移到了MyCallable_iAny1任务,并不会打印出异常信息。如果,想打印出异常信息,需要这样写:

    写法一:

                    try{
    			if(true){
    				throw new Exception("myException_B");
    			}
    		}catch(Exception e){
    			e.printStackTrace();
    }

    运行结果:

    java.lang.Exception: myException_B
    call_2
    	at myexecutorservice.MyCallable_iAny2.call(myinvokeAny.java:76)
    	at myexecutorservice.MyCallable_iAny2.call(myinvokeAny.java:1)
    

    这里获得了异常任务的结果,这是因为MyCallable_iAny2的异常状态未上报,这导致线程池认为其是正确的,从而未将关注点换到下一个任务

    写法二:

    try{
    			if(true){
    				throw new Exception("myException_B");
    			}
    		}catch(Exception e){
    //			e.printStackTrace();
    			throw e;
    		}
    

    运行结果:

    finish
    call_1
    

      这里抛出了异常,从了线程池将关注点换到了下一个任务

  • 相关阅读:
    国内外常用学术论文搜索网站
    2019年全国高校sql数据库
    Flask无法访问(127.0.0.1:5000)的问题解决方法
    Windows终端命令行工具Cmder
    JQuery实现密码可见不可见
    区块链最大的难题及其解决方案
    python 下载 进度条
    centos 用docker 运行 cypress
    通过 centos Nginx 查看html (为后续 服务器生成html 方便访问)
    odoo 分享 PostgreSQL 语句2
  • 原文地址:https://www.cnblogs.com/l1019/p/6755992.html
Copyright © 2011-2022 走看看