점점 길어지는 백오프로 재시도하기

FxDart 승 async

요구사항

환율 서비스는 정확히 두 번 응답하지 않다가 그다음부터 응답합니다. 점점 길어지는 백오프로 재시도하세요 — 첫 실패 뒤에는 40 ms, 두 번째 실패 뒤에는 80 ms 대기 — 시도 예산은 세 번입니다. 페이로드, 시도 횟수, 그리고 기록된 백오프 시퀀스를 출력하세요(각 대기가 선택되는 시점에 기록되므로 출력은 결정적입니다). 두 버전 모두 예상 출력 아래에 표시된 줄들을 출력해야 합니다.

예상 출력

rates: EUR 0.85, GBP 0.74, JPY 148.20
attempts: 3
backoff: 40ms, 80ms

나란히 보기

RxDart

import 'package:rxdart/rxdart.dart';

var attempts = 0;
final backoffMs = <int>[];

/// The FX rate service: unavailable exactly twice, then serves.
Future<String> fetchRates() async {
  attempts += 1;
  await Future<void>.delayed(const Duration(milliseconds: 10));
  if (attempts < 3) throw StateError('rate service unavailable');
  return 'rates: EUR 0.85, GBP 0.74, JPY 148.20';
}

Future<void> main() async {
  var failures = 0;
  // retryWhen wants a NOTIFIER stream per error: emit → retry, error →
  // give up. Backoff means mapping each failure to a timer stream, and
  // the attempt budget is tracked by hand outside the factory.
  final payload = await Rx.retryWhen(
    () => Rx.fromCallable(fetchRates),
    (error, stackTrace) {
      failures += 1;
      if (failures >= 3) return Stream<void>.error(error, stackTrace);
      final ms = 40 * failures;
      backoffMs.add(ms);
      return Rx.timer<void>(null, Duration(milliseconds: ms));
    },
  ).first;

print(payload);
  print('attempts: $attempts');
  print('backoff: ${backoffMs.map((ms) => '${ms}ms').join(', ')}');
}

FxDart

차이가 나는 이유

백오프는 단순 재시도의 호출-하나 대칭이 깨지는 지점입니다. RxDart의 retryWhen은 메타-스트림 프로토콜입니다: 오류가 날 때마다 팩토리가 알리미 스트림을 반환해야 합니다 — 값을 내보내면 재시도가 촉발되고, 오류를 내보내면 포기합니다. 그래서 "40 ms 기다렸다가, 다음엔 80 ms"는 각 실패를 Rx.timer 스트림으로 매핑하는 일이 되고, 팩토리는 한 번에 오류 하나만 보기 때문에 실패 횟수와 시도 예산이 모두 연산자 바깥의 가변 변수에 놓입니다. 동작하고, 최대한으로 일반적이기도 합니다 — 하지만 스트림으로 재시도 루프를 손수 조립하고 있는 셈입니다.

FxDart는 백오프를 그것의 본모습대로 다룹니다: 지금까지 몇 번 실패했는지에 따라 정해지는 숫자 하나. retry의 delay 훅은 실패 횟수(1, 2, …)를 받아 Duration을 반환합니다 — 정책 전체가 표현식 하나이고, 예산은 이전과 같은 attempts 인자입니다. 시도 사이에 기다리는 일에 스트림이 필요할 이유는 없고, 풀 쪽은 필요한 척도 하지 않습니다.

판정은 FxDart, 개념 수 기준입니다: 훅 하나 vs 알리미 스트림 팩토리, 외부 카운터, 실패마다 하나씩의 타이머 스트림.

벤치마크

Apple M1 Max, RAM 32 GB · Dart 3.12.2 (AOT 컴파일) · 2026-08-18

비동기 예제입니다. 대표 스케일이 1,000,000이 아니라 N = 10,000인 이유 — 원소 하나마다 양쪽 모두 이벤트 루프를 한 바퀴 돌아야 하므로, 실제 await 백만 번은 파이프라인이 아니라 Dart 이벤트 루프를 몇 분씩 재게 됩니다. 지연은 0으로 두고 예제의 동시성 제한은 그대로 유지합니다. 막대가 비교하는 것은 파이프라인 기계 장치 자체입니다.

N = 100

시간 무승부

RxDart 687 µs

FxDart 575 µs

최대 메모리 무승부

RxDart 17.0 MB

FxDart 16.5 MB

N = 10,000

시간 FxDart 승

RxDart 57.5 ms

FxDart 44.2 ms

최대 메모리 FxDart 승

RxDart 29.4 MB

FxDart 27.1 MB

막대는 사이드별로 새 프로세스에서 반복 측정한 중앙값입니다(작은 N은 타이머 해상도를 위해 배치 처리). 두 사이드가 서로 5% 이내이거나 — 사람이 지각할 수 없는 차이인 0.6ms 이내이면 — 무승부로 칩니다. 상대 차이가 근소한 경우는 최대 5회까지 다시 측정합니다. 앱에서는 어느 막대가 짧든 몇 밀리초 이하의 차이는 사용자에게 보이지 않습니다. 메모리는 프로세스 최대 RSS입니다. Dart VM과 데이터셋은 양쪽이 동일하므로, 두 막대의 차이가 곧 파이프라인 자체가 붙들고 있는 양입니다.