并发包CallableAndFuture

Posted 2020-09-19 安静

/**
 * 
 * @描述: Callable   Future
 * 
 *    程序运行一个线程，线程运行结束后，我们可以获取另一个线程的结果
 *      
 * @作者: Wnj .
 * @创建时间: 2017年5月16日 .
 * @版本: 1.0 .
 */
public class CallableAndFuture {
    
    /**
     * 单个任务
     * <功能详细描述>
     */
    public static void single() {
        ExecutorService threadPool = Executors.newSingleThreadExecutor();
        /**
         * 需要返回结果的就使用submit
         */
        Future<String> future = threadPool.submit(new Callable<String>() {
            public String call() throws Exception {
                Thread.sleep(2000);
                return "hello";
            };
        });
        System.out.println("等待拿到结果");
        try {
            System.out.println("拿到结果" + future.get());
            // System.out.println("拿到结果" + future.get(1,TimeUnit.SECONDS));//1秒钟内必须返回
        }
        catch (InterruptedException e) {
            e.printStackTrace();
        }
        catch (Exception e) {
            e.printStackTrace();
        }
    }
    /**
     * 多个任务
     * <功能详细描述>
     */
    public static void array() {
        ExecutorService threadPool2 = Executors.newFixedThreadPool(10);
        /**
         * 一定就提交一组Callable任务,只要一个任务完成了就能获取到结果
         */
        CompletionService<Integer> completionService = new ExecutorCompletionService<Integer>(threadPool2);
        for (int i = 1; i <= 10; i++) {
            final int seq = i;
            completionService.submit(new Callable<Integer>() {
                @Override
                public Integer call() throws Exception {
                    Thread.sleep(new Random().nextInt(5000));
                    return seq;
                }
            });
        }
        for (int i = 0; i < 10; i++) {
            try {
                System.out.println(completionService.take().get());
            }
            catch (InterruptedException e) {
                e.printStackTrace();
            }
            catch (ExecutionException e) {
                e.printStackTrace();
            }
        }
    }
    
    /**
     * @param args
     */
    public static void main(String[] args) {
        array();
    }