带有返回值的 Callable 使用

package com.afengzi.training.comcurrency;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.*;

/**
* Created with IntelliJ IDEA.
* User: afengzi
* Date: 14-10-9
* Time: 下午5:06
* 实现有返回值的Callable接口
*/
public class Acallable{

    public static void main(String args[]){

        ExecutorService service = Executors.newCachedThreadPool() ;
        List<Future<String>> futures = new ArrayList<Future<String>>() ;
        for (int i = 0 ; i< 5 ; i++){
            Future<String> future = service.submit(new $Call(100)) ;
            futures.add(future) ;
        }
        service.shutdown();
        System.out.println("main -- "+Thread.currentThread().getName());
        for (Future<String> future : futures){
            if (future.isDone()){
                try {
                    System.out.println(future.get());
                } catch (InterruptedException e) {
                    e.printStackTrace();
                } catch (ExecutionException e) {
                    e.printStackTrace();
                }
            }
        }
    }

    public static class $Call implements Callable<String>{
        private int index ;

        public $Call(int index){
            this.index = index ;
        }
        @Override
        public String call() throws Exception {
            int first = 1 ;
            int second = 1 ;
            int third = 0 ;
            while (true){
                third = first+second ;
                if (third > index){
                    break;
                }
                first = second ;
                second = third ;
            }
            System.out.println("sub -- "+Thread.currentThread().getName());
            return third+"" ;
        }
    }


}

作者：klov001 发表于2014-10-9 18:24:10 原文链接

阅读：92 评论：0 查看评论