Guava 的一个异步service类 工具

public static ListeningExecutorService EXECUTOR_SERVICE = MoreExecutors.listeningDecorator(Executors.newFixedThreadPool(10));


    public static void exec(final FutureService objService, final Object... args) {
        // 异步处理
        ListenableFuture<Object> explosion = EXECUTOR_SERVICE.submit(
                new Callable<Object>() {
                    public Object call() {
                        Object o = null;
                        try {
                            o = objService.handler(args);
                        } catch (Exception e) {
                            log.error(e, "异步错误");
                        }

                        return o;
                    }
                });
        Futures.addCallback(explosion, new FutureCallback<Object>() {
            @Override
            public void onSuccess(Object o) {
                // TODO 成功处理
                objService.onSuccess(o, args);
            }

            @Override
            public void onFailure(Throwable throwable) {
                // TODO 失败处理
                objService.onFailure(throwable, args);
            }
        });
    }

 这段代码可以 可以当场一个工具类，把需要执行的异步操作包装成一个类（FutureService）传进来。

public interface FutureService {
    /**
     * 执行的方法
     *
     * @param args
     * @return
     */
    Object handler(Object... args);

    /**
     * 成功后执行
     *
     * @param result 执行的结果
     * @param args   传递参数（执行方法中的args）
     */
    void onSuccess(Object result, Object... args);

    /**
     * 失败后执行
     *
     * @param args      传递参数（执行方法中的args）
     * @param throwable
     */
    void onFailure(Throwable throwable, Object... args);
}

 

将 需要异步执行的动作继承这个借口。将需要执行的代码

 InfFuture.exec(auditDTService, impcompanyId,auditImport.getId());

 

 

一个异步的工具类 可以直接放在代码里面用。基于 guava 的 ListenableFuture的异步调用 Futures.addcallback（future,new Futurecallback） 来处理回掉