java多线程异步回调Future

Posted 2021-07-07 500年

java多线程-异步回调Future

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.TimeUnit;

public class FutureDemo {

	public static void main(String[] args) throws Exception {
		CompletableFuture<Void> completableFuture = CompletableFuture.runAsync(() -> {
			try {
				TimeUnit.SECONDS.sleep(2);
			} catch (Exception e) {
				e.printStackTrace();
			}
			System.out.println(Thread.currentThread().getName() + " 执行");
		});
		System.out.println("11111111111");
		completableFuture.get();
		
		
		CompletableFuture<Long> completableFuture2 = CompletableFuture.supplyAsync(()->{
			int a=10/0;
			return 1024L;
		});
		
		Long result = completableFuture2.whenComplete((t,u)->{
			System.out.println("t:"+t);
			System.out.println("u:"+u);
		}).exceptionally((e)->{
			System.out.println(e.getMessage());
			return 1023L;
		}).get();
		System.out.println(result);
	}

}

特别鸣谢：狂神说Java老师的无私奉献

.
.
.
上一篇 java多线程（八）ForkJoin分支合并
下一篇 java多线程（十） JMM理解 Volatile