使用ListenableFuture

使用一种可监听的future 测试demo

public class TestListenableFuture {


    public static void main(String[] args) {
        ExecutorService delegate = Executors.newSingleThreadExecutor();
        ListeningExecutorService listeningExecutorService = MoreExecutors.listeningDecorator(delegate);

        Callable callable  = new Callable<String>() {
            @Override
            public String call() throws Exception {
                int i = 0;
                while (true){
                    Thread.currentThread().sleep(3000);
                    i++;
                    System.out.println("test call ,count =" + i);
                    if (i == 5){
                        System.out.println(1/0);
                        return "liyan";
                    }
                }

            }
        };
        ListenableFuture submit = listeningExecutorService.submit(callable);
        /**
        添加监听线程， 在任务成功或失败时候做出反应
        */
        Futures.addCallback(submit, new FutureCallback<String>() {
            @Override
            public void onSuccess(@Nullable String result) {
                System.out.println(" ok ,success");
            }

            @Override
            public void onFailure(Throwable t) {
                System.out.println("not ok ,exeception "  + t.getMessage() );
            }
        },listeningExecutorService);


        int i = 0;
        while (true){
            try {
                Thread.currentThread().sleep(3000);
                i++;
                System.out.println("main thread  ,count =" + i);

            }catch (Exception e){

            }
        }

    }
}