Java异步代码

    // 异步操作
    ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(1,
            1,
            0L,
            TimeUnit.MILLISECONDS,
            new ArrayBlockingQueue<>(2),
            new ThreadPoolExecutor.AbortPolicy());
    CompletableFuture.runAsync(() -> {
        try {
            // 这里填写需要异步处理的代码方法
        } catch (Exception e) {
            e.printStackTrace();
        }
    }, threadPoolExecutor);
    threadPoolExecutor.shutdown();