多线程-CompletionService

╰半夏微凉° 2022-07-15 00:14 114阅读 0赞

转载地址：  http://langgufu.iteye.com/blog/2102549

这个类就相当于打包了一个系列的Future，然后把这个写结果放到一个集合中。 同时，放入的时候如果有延迟，取出来也有延迟。

package cn.stu;
    
    import java.util.concurrent.Callable;
    import java.util.concurrent.CompletionService;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.ExecutorCompletionService;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.Future;
    
    public class Main {
        
    	private static  int index = 0; 
    	 
    
    	public static void main(String[] args) throws InterruptedException, ExecutionException {
    		 
              Main.resultMsg();
    	}
    	
    	
    	public static  void  resultMsg() throws InterruptedException, ExecutionException{
    		
    		ExecutorService  executor = Executors.newFixedThreadPool(1);
    		CompletionService<String> execomp = new ExecutorCompletionService<>(executor);
    		
    		// 放了10个任务进入
    		int count = 0; 
    		for(count = 0; count<5; count++){
    			 
    			 execomp.submit(new Callable<String>() {
    				
    				@Override
    				public String call() throws Exception {
    					index++;
    					if(index == 4){
    						Thread.sleep(5000);
    					}
    					return "who--->"+index;
    				}
    			});
    		}
    		
    		// 获取每一个任务的返回
    		Future<String> futures = null;
    		StringBuilder  result = new StringBuilder();
    		String msg = null;
    		for(int i =0; i<5; i++){
    			
    			 futures =  execomp.take(); // 获取任务的时候， 会有阻塞。 
    			 msg = futures.get(); 
    			 System.out.println("队列数据获取--->"+msg); 
    			 if(i == index-1){
    				 System.out.println("前面的都是马上打印出来， 在9的时候，会阻塞，延长2秒");
    			 }
    			 result.append(msg);
    		}
    		
    		System.out.println("返回结果集--->"+result);
    		executor.shutdown();
    	}
    	
    	
    	
    	
    	
    	
    
    }

运行结果如下：

队列数据获取--->who--->1  
队列数据获取--->who--->2  
队列数据获取--->who--->3  
队列数据获取--->who--->4  
队列数据获取--->who--->5  
前面的都是马上打印出来， 在4的时候，会阻塞，延长2秒  
返回结果集--->who--->1who--->2who--->3who--->4who--->5