CompletableFuture 异步任务

@SpringBootTest
class Demo3ApplicationTests {

    @Test
    void contextLoads() {
        run();
    }


    private void run() {
        CompletableFuture<Void> f1 = CompletableFuture.runAsync(() -> {
            try {
                Thread.sleep(3000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("第一个异步任务");
        });

        CompletableFuture<Void> f2 = CompletableFuture.runAsync(() -> {
            try {
                Thread.sleep(2000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("第二个异步任务");
        });
        CompletableFuture.allOf(f1, f2).join();

        f2.whenComplete(((aVoid, throwable) -> {
            System.out.println("void f2" + aVoid);
        }));

        f1.whenComplete(((aVoid, throwable) -> {
            System.out.println("void f1" + aVoid);
        }));
        System.out.println("CompletableFuture Test runAsync");
    }

}

class Foo {
    private Integer first;

    public Integer getFirst() {
        return first;
    }

    public void setFirst(Integer first) {
        this.first = first;
    }
}
public static void main(String[] args) {
    Foo f = new Foo();
    Consumer<Foo> consumer_fun = foo->foo.setFirst(1);
    consumer_fun.accept(f);
    System.out.println(f.getFirst());
}