добрый день , как построить такой pipeline :
stream->map to completablefuture join all -> get object
Есть коллекция Enitity -> List<Enitity>
Есть сервис куда их нужно передать он изменят их состояние , что то с ними делает ,
Есть сервис который их сохраняет в базу .
Enitity Spring repository
Для примера :
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.
39.
40.
41.
42.
43.
44.
45.
46.
47.
48.
49.
50.
51.
52.
53.
54.
55.
class Person {
public String firstName;
public String lastName;
public String fullName;
@Override
public String toString() {
return firstName + " " + lastName;
}
public Person(String firstName, String lastName) {
this.firstName = firstName;
this.lastName = lastName;
}
}
private static Person renamePerson(Person p) {
p.fullName = p.firstName + " : " + p.lastName;
return p;
}
@Test
public void testMap() {
final ThreadFactory threadFactory = new ThreadFactoryBuilder()
.setNameFormat("Поток-%d")
.setDaemon(true)
.build();
final ExecutorService es = Executors.newFixedThreadPool(2, threadFactory);
List<Person> persons = Arrays.asList(new Person("1", "2"), new Person("3", "4"));
//1
CompletableFuture[] futures
=
persons.stream()
.map(p -> CompletableFuture.supplyAsync(
() -> renamePerson((Person) p), es))
.map(f -> f.thenAccept(System.out::println))
.toArray(size -> new CompletableFuture[size]);
//2
CompletableFuture.allOf(futures).join();
//3 тут сохраняем в базу
persons.stream().forEach(p -> System.out.println(p.fullName));
Хочется сделать 1+ 2 + 3 в одном стриме , вопрос как ?
чтобы не терять тип и не получать на 2 шаге CompletableFuture<Void> видимо
а вернуть CompletableFuture<Person> ...
