파이프라인이 스트림 소비자로 이어질 때
요구사항
주문 상태 다섯 건을 가져오되 동시 진행 요청은 최대 두 개, 결과는 소스 순서대로 — 그런 다음 결과를 둘씩 배치로 묶어 각 배치를 출력하는 하류 소비자에게 넘기세요. 조회 지연은 코드에 고정되어 있습니다; 두 버전 모두 예상 출력 아래에 표시된 줄들을 출력해야 합니다.
예상 출력
batch 1: A-101 shipped | A-102 packed batch 2: A-103 allocated | A-104 delayed batch 3: A-105 shipped
나란히 보기
RxDart
FxDart
차이가 나는 이유
RxDart는 끝에서 끝까지 스트림으로 달립니다:
maxConcurrent: 2를 단 flatMap이 fetch에
제한을 걸고 bufferCount(2)가 결과를 둘씩 짝짓습니다.
단서 하나가 가운데에 삽니다: 동시 flatMap은
완료 순서로 내보내므로, 이 패널이 소스 순서로 출력되는
것은 지연들이 우연히 그 순서로 완료되기 때문입니다 — 동시성
아래에서의 재정렬은 푸시 모델의 기본값이고, 일반적으로 소스
순서를 지키려면 모아서 정렬해야 합니다.
FxDart 패널은 이전 예제의 다리를 반대 방향으로 건넌 것입니다.
가져오는 절반은 풀 파이프라인이고 —
mapConcurrent(2, …)는 지연이 어떻게 굴든 구조적으로
순서를 지킵니다 — chunk(2)(FxDart의
bufferCount)가 결과를 둘씩 짝짓고,
toStream()이 배치들을 임의의 스트림 소비자에게
넘깁니다. 여기서 그 소비자는 출력만 하지만, RxDart 앱이라면
브리지된 스트림 위에서 Rx 연산자들로 계속 이어 갈 수 있습니다:
생산자는 누가 소비하는지 신경 쓰지 않습니다. 그 분업이 곧
판정입니다: 제한 있고, 순서 있고, 타입 있는 일은 풀 파이프라인에서
하고, 그것을 Stream으로 노출한 뒤, 푸시 어휘(버퍼링,
디바운싱, UI 바인딩)가 더 잘 맞는 곳부터는 푸시 세계가 이어받게
하세요. 무승부 — 다리가 곧 요점입니다.
벤치마크
비동기 예제입니다. 대표 스케일이 1,000,000이 아니라 N = 10,000인 이유 — 원소 하나마다 양쪽 모두 이벤트 루프를 한 바퀴 돌아야 하므로, 실제 await 백만 번은 파이프라인이 아니라 Dart 이벤트 루프를 몇 분씩 재게 됩니다. 지연은 0으로 두고 예제의 동시성 제한은 그대로 유지합니다. 막대가 비교하는 것은 파이프라인 기계 장치 자체입니다.
N = 100
시간 무승부
최대 메모리 무승부
N = 10,000
시간 무승부
최대 메모리 FxDart 승
막대는 사이드별로 새 프로세스에서 반복 측정한 중앙값입니다(작은 N은 타이머 해상도를 위해 배치 처리). 두 사이드가 서로 5% 이내이거나 — 사람이 지각할 수 없는 차이인 0.6ms 이내이면 — 무승부로 칩니다. 상대 차이가 근소한 경우는 최대 5회까지 다시 측정합니다. 앱에서는 어느 막대가 짧든 몇 밀리초 이하의 차이는 사용자에게 보이지 않습니다. 메모리는 프로세스 최대 RSS입니다. Dart VM과 데이터셋은 양쪽이 동일하므로, 두 막대의 차이가 곧 파이프라인 자체가 붙들고 있는 양입니다.