modern-java-libs

모던 자바 인 액선(8,9,10) 스터디 정리

@FunctionalInterface	기능	함수 syntax	Method Syntax	스트림 연산	예시
Runnable	쓰레드	() -> void	void run()	-
Callable	쓰레드	() -> V	V call() throws Exception	-
Comparator	정렬	(T, T) -> int	int compare(T o1, T o2)	sorted
Predicate	필터링	(T) -> boolean	boolean test(T t)	filter, allMatch, anyMatch, noneMatch	Collection::isEmpty
Consumer	소비	(T) -> void	void accept(T t)	forEach	System.out::println
Function<T, R>	매핑	(T) -> R	R apply(T t)	map	Arrays::asList
BiFunction<T, U, R>	매핑	(T, U) -> R	R apply(T t, U u)	reduce
BinaryOperator	리듀싱	(T, T) -> T	T apply(T t, T t)	reduce	BigInteger::add
UnaryOperator	리듀싱	(T) -> T	T apply(T t, T t)	reduce	String::toLowerCase
Supplier	생성	() -> T	T get()	-	Instant::now

스트림 API
- 선언형 프로그래밍 like SQL
- 병렬연산 지원
- 조립할 수 있음
  - 중간 연산
    - 필터링: filter
    - 슬라이싱: takeWhile, dropWhile <== Java9
    - 정렬: sorted
    - 검색: findAny, findFirst
    - 매칭: allMatch, anyMatch, noneMatch
    - 매핑: map
    - 리듀싱: reduce
    - 축소: limit
    - 중복제거: distinct (stable only for ordered stream)
  - 단말(최종) 연산
    - 수집: collect
    - 갯수: count
    - 방문: foEach
- 기타 특징
  - 게으른 연산
  - 쇼트서킷(short circuit)
  - 루프 퓨전(loop fusion)
    - Java 8 스트림
메서드에 코드를 전달(메서드 참조 & 람다)
- 동작 파라미터화(behavior parameterization)
- 7까지는 익명 클래스를 이용
- 람다 -> 함수형 프로그래밍 가능
인터페이스의 디폴트 메서드

유형	팩토리 메서드	리턴 타입	설명	예시
구조변환	toList	List	리스트로 수집	stream().collect(toList())
구조변환	toSet	Set	Set으로 수집	stream().collect(toSet())
구조변환	toCollection	Collection	지정 타입으로 수집	stream().collect(toCollection(), ArrayList::new)
리듀싱	counting	Long	아이템 수	stream().collect(counting())
리듀싱	summingInt	Integer	합계	stream().collect(summingInt(Dish::getCalories))
리듀싱	averagingInt	Double	평균	stream().collect(averagingInt(Dish::getCalories))
리듀싱	summarizingInt	IntSummaryStatistics	통계	stream().collect(summarizingInt(Dish::getCalories))
리듀싱	joining	String	문자열 연결	stream().map(Dish::getName).collect(joining(", "))
리듀싱	maxBy	Optional	최댓값	stream().collect(maxBy(comparingInt(Dish::getCalories))
리듀싱	minBy	Optional	최솟값	stream().collect(minBy(comparingInt(Dish::getCalories))
리듀싱	reducing	아이템 타입	계산방식	stream().collect(reducing(0, Dish::getCalories, Integer::sum))
그루핑	groupingBy	Map<K, List>	그루핑 결과	stream().collect(groupingBy(Dish::getType))
분할	partitioningBy	Map<Boolean, List>	2개로 그루핑	stream().collect(partitioningBy(Dish::isVegetarian))
?	collectingAndThen	-	-	stream().collect(collectingAndThen(toList(), List::size))

유형	예시	같은 기능을 하는 람다
static 메서드 참조	Integer::parseInt	str -> Integer.parseInt(str)
인스턴스 메서드 참조(한정적)	Instant.now()::isAfter	Instant then = Instant.now(); t -> then.isAfter(t)
인스턴스 메서드 참조(비한정적)	String::towLowerCase	str -> str.toLowerCase()
클래스 생성자	TreeMap<K,V>::new	() -> new TreeeMap<K,V>
배열 생성자	int[]::new	len -> new int[len]

CompletableFuture: Java 8 (non-blocking)
- Future에 대한 선언형 구문 제공
- 동시성 Task 의존성을 파이프라인 형식으로 관리
- Future is Collection-style -- CompletableFutre is Stream-style
CompletableFuture API List

join
complete	T -> boolean
allOf	CompletableFutre... -> CompletableFutre
anyOf	CompletableFutre... -> CompletableFutre
supplyAsync	Supplier -> CompletableFuture
thenApply	Function -> CompletableFuture	I/O가 없는 Operation
thenCompose	Function<T, CompletableFuture> -> CompletableFuture	의존 CF 연결
thenCombine	CompletableFuture, Function<T, U> -> CompletableFuture	독립 CF 연결
thenAccept	Consumer -> CompletableFuture
orTimeOut	(long, TimeUnit) -> CompletableFuture	지연된 Future 예외처리
completeOnTimeOut	(T, long, TimeUnit) -> CompletableFuture	지연된 Future 기본값 할당

CompletableFuture: Java 8 (non-blocking)
java.util.concurrent.Flow: Java 9
- Pivotal: Reactor
- Netflix: RxJava
- 라이트벤드: Akka 스트림
- Redhat: Vert.x
pub-sub 모델
리액티브 애플리케이션
- 이벤트 드리븐
- 시간에 기반한 비동기, 동시적, 비결합 -> 회복성(resilient)
리액티브 시스템
- 메시지 드리븐
- 위치 투명성 -> 공간적 비결합 -> 탄력성(elastic)