java基础

interface可以多继承

DTO中使用包装类 Integer,不要使用int， 防止set时出现NPE

xx.setXAmount(jsonObject.getInteger("returncount"));

使用spring mvc的异步线程 因为都会返回response，会调用Future对象的get方法，如果后台有sql异常是可以打印的.

但是会有一些异步处理的场景，使用了CompleteFuture.supplyAsync()又没有调用get方法，会造成异常不打印。如果确定不调用Future.get，最好还是使用没有返回值的ExecutorService.execute(Runnable),而不是submit方法

public class FutureUtilTest {


    public static void main(String[] args) {
        MyPool myPool = new MyPool(2, 4, 0, TimeUnit.DAYS, new ArrayBlockingQueue(5555));
        FutureAsyncUtil.setExecutor(myPool);

        CompletableFuture<Integer> supply = FutureAsyncUtil.supply(() -> {
            System.out.println(1111);
            if (1 == 1) {
                throw new IllegalArgumentException("000");
            }
            return 1;
        });
        /*try {
            supply.get();//如果不get， 即使抛出异常,使用了afterExecute，也打印不出来
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (ExecutionException e) {
            e.printStackTrace();
        }*/

        FutureAsyncUtil.execute(()->{
            System.out.println(3333);
            if (1 == 1) {
                throw new IllegalArgumentException("3333");
            }
        });
        myPool.shutdown();//没有shutdown jvm不会退出

        System.out.println("END");
    }
}


class MyPool extends ThreadPoolExecutor {

    public MyPool(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue) {
        super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue);
    }

    @Override
    protected void afterExecute(Runnable r, Throwable t) {
        super.afterExecute(r, t);
        if (t != null) {
            System.out.println("1111111" + t.getMessage());
        }
    }
}