Java线程池之FutureTask【Java线程池系列3】

本是古典何须时尚 2023-10-16 22:33 149阅读 0赞

**Java线程池之FutureTask【Java线程池系列3】**

在附录的文章2中，使用了Java的线程池和Future、Callable。本篇文章在文章2的基础上加以改进，基于FutureTask，换掉Future重新实现。  
FutureTask既实现了Future，也实现了Runnable，所以更加的普适，用法和Future相类似。和附录的文章2代码写法类似，比如：

package test_java;
    
    import java.util.ArrayList;
    import java.util.concurrent.Callable;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.FutureTask;
    
    public class ZhangPhilExecutorService {
    
    	private final int POOL_SIZE = 5;
    	private final int TOTAL_THREAD = 6;
    
    	public ZhangPhilExecutorService() {
    
    		// 创建容量为 POOL_SIZE 的线程池。
    		ExecutorService pool = Executors.newFixedThreadPool(POOL_SIZE);
    
    		final ArrayList<FutureTask<String>> futures = new ArrayList<FutureTask<String>>();
    
    		for (int i = 0; i < TOTAL_THREAD; i++) {
    
    			AThread t = new AThread(i);
    
    			//在此处使用FutureTask实现，注意写法
    			FutureTask<String> futureTask = new FutureTask<String>(t);
    			futures.add(futureTask);
    			pool.submit(futureTask);
    		}
    
    		System.out.println("获取结果中...");
    		for (FutureTask<String> f : futures) {
    			try {
    				// if (f.isDone())
    					System.out.println(f.get());
    			} catch (Exception e) {
    				e.printStackTrace();
    			}
    		}
    		System.out.println("得到全部结果.");
    
    		// 关闭线程池。
    		pool.shutdown();
    	}
    
    	private class AThread implements Callable<String> {
    
    		private int id;
    
    		public AThread(int id) {
    			this.id = id;
    		}
    
    		@Override
    		public String call() {
    			System.out.println("线程:" + id + " -> 运行...");
    			try {
    				Thread.sleep(3000);
    			} catch (InterruptedException e) {
    				e.printStackTrace();
    			}
    			System.out.println("线程:" + id + " -> 结束");
    			return "返回的字符串" + id;
    		}
    	}
    
    	public static void main(String[] args) {
    		new ZhangPhilExecutorService();
    	}
    }

注意，FutureTask和Future在get返回值时候，都将阻塞，所以，为了避免阻塞，可以加一条判断语句isDone，完成了才get，否则不予get。另外，FutureTask还有Future在get的时候，还有一个相类似的方法体：  
public V get(long timeout,TimeUnit unit);  
可以设置超时时间，那么在get时候如果超时则返回，从另外一个途径实现非阻塞获取返回数据。

附录我以前写的相关文章：  
【文章1】《Java线程池：ExecutorService，Executors》链接地址：[http://blog.csdn.net/zhangphil/article/details/43898637][http_blog.csdn.net_zhangphil_article_details_43898637]  
【文章2】《Java线程池及Future、Callable获得线程返回结果【Java线程池系列2】》链接地址：[http://blog.csdn.net/zhangphil/article/details/49701219][http_blog.csdn.net_zhangphil_article_details_49701219]

[http_blog.csdn.net_zhangphil_article_details_43898637]: http://blog.csdn.net/zhangphil/article/details/43898637
[http_blog.csdn.net_zhangphil_article_details_49701219]: http://blog.csdn.net/zhangphil/article/details/49701219