CompletableFuture - 常用API（下） - jvisualvm

fairy_xzc

浏览: 359947 次
性别:
来自: 北京

最近访客更多访客>>

huan0727

漂移361john

scj2cy

smallbug2010

博主相关

博客

微博

相册

留言

关于我

文章分类

社区版块

存档分类

CompletableFuture - 常用API（下）

博客分类：

Concurrent

原创转载请注明出处：http://agilestyle.iteye.com/blog/2427515

runAfterBoth

private static void testRunAfterBoth() {
	CompletableFuture.supplyAsync(() -> {
		System.out.println(Thread.currentThread().getName() + " is running");
		return 1;
	}).runAfterBoth(CompletableFuture.supplyAsync(() -> {
		System.out.println(Thread.currentThread().getName() + " is running");
		return 2;
	}), () -> System.out.println("action ended..."));
}

Console Output

applyToEither

private static void testApplyToEither() {
	CompletableFuture.supplyAsync(() -> {
		System.out.println(Thread.currentThread().getName() + " is running");
		return CompletableFutureTest6.get();
	}).applyToEither(CompletableFuture.supplyAsync(() -> {
		System.out.println(Thread.currentThread().getName() + " is running");
		return CompletableFutureTest6.get();
	}), v -> v * 10)
	.thenAccept(System.out::println);
}

Console Output

acceptEither

private static void testAcceptEither() {
	CompletableFuture.supplyAsync(() -> {
		System.out.println(Thread.currentThread().getName() + " is running");
		return CompletableFutureTest6.get();
	}).acceptEither(CompletableFuture.supplyAsync(() -> {
		System.out.println(Thread.currentThread().getName() + " is running");
		return CompletableFutureTest6.get();
	}), System.out::println);
}

Console Output

runAfterEither

private static void testRunAfterEither() {
	CompletableFuture.supplyAsync(() -> {
		System.out.println(Thread.currentThread().getName() + " is running");
		return CompletableFutureTest6.get();
	}).runAfterEither(CompletableFuture.supplyAsync(() -> {
		System.out.println(Thread.currentThread().getName() + " is running");
		return CompletableFutureTest6.get();
	}), () -> System.out.println("action ended..."));
}

Console Output

anyOf

private static void testAnyOf() {
	List<CompletableFuture<Double>> result = Stream.of(1, 2, 3, 4, 5)
			.map(i -> CompletableFuture.supplyAsync(CompletableFutureTest6::get))
			.collect(toList());

	CompletableFuture.anyOf(result.toArray(new CompletableFuture[result.size()]))
			.thenRun(() -> System.out.println("action ended..."));
}

Console Output

allOf

private static void testAllOf() {
	List<CompletableFuture<Double>> result = Stream.of(1, 2, 3, 4, 5)
			.map(i -> CompletableFuture.supplyAsync(CompletableFutureTest6::get))
			.collect(toList());

	CompletableFuture.allOf(result.toArray(new CompletableFuture[result.size()]))
			.thenRun(() -> System.out.println("action ended..."));
}

Console Output