비동기 프로그래밍

•

Future

•

async, await

•

Stream

Future

종료되지 않은 비동기 요청의 결과를 가리키는 클래스

요청 후, 결과를 나중에 받기 위해 사용

Future<반환타입> 메소드명() async {
	
	return 반환값;
}
Dart
복사

// 5초 지연
Future<void> fetchOrder1() async {

  // Future.delayed( 지연, 콜백함수 )
  Future.delayed(const Duration(seconds: 5), () {
    print('5초후 출력...');
  });
}

// 3초 지연
Future<void> fetchOrder2() async {

  // Future.delayed( 지연, 콜백함수 )
  Future.delayed(const Duration(seconds: 3), () {
    print('3초후 출력...');
  });
}

void main(List<String> args) {
  fetchOrder1();
  fetchOrder2();
  print('요청 중...');
}
Dart
복사

Future<String> fetchData() {
  return Future.delayed(Duration(seconds: 2), () {
    return '결과 데이터';
  });
}

void fetchDataAwait() async {
  String result = await fetchData();
  print(result);
}

void main(List<String> args) {
  // then(data) 
  // : Future 가 완료된 후, 반환값 data 를 가져와서, 
  //   특정 작업을 수행하는 메소드 
  fetchData().then((data) {
    print(data);
    print('추가 작업...');
  });

  fetchDataAwait();
  print('요청 중...');
}
Dart
복사

async, await

aysnc

함수가 비동기로 실행되도록 지정하는 키워드

async 함수는 비동기로 실행되는 Future 객체를 반환합니다.

Future<void> exampleAsyncFunction() async {
  // 비동기 작업 수행
}
Dart
복사

await

async 함수 내에서 Future 완료 시, 함수 실행을 기다려서 결과값을 반환해주는 키워드

Future<void> exampleAsyncFunction() async {
  // 비동기 작업 수행
  var result = await someAsyncOperation();
  print(result);
}
Dart
복사

Stream

비동기 작업 결과를 순차적으로 처리하는 클래스

Stream<int> countStream(int to) async* {
  for(int i = 1 ; i <= to ; i++ ){
    await Future.delayed(Duration(seconds: 1), () {
      print('요청 : $i');
    });
    yield i;
  }
}

Future<int> sumStream(Stream<int> stream) async {
  var sum = 0;
  print('합계');
  await for(final value in stream ) {
    sum += value;
    print('전달된 값 : $value - sum : $sum');
  }
  return sum;
}


Future<void> main(List<String> args) async {
  var stream = countStream(10);
  var sum = await sumStream(stream);
  print('요청중...');
  print(sum);
  print(stream);
}
Dart
복사

코드 실행 흐름

main 함수에서 countStream(10)을 호출하여 Stream 객체를 생성합니다.

sumStream 함수에 Stream을 전달하여 합계를 계산합니다.

countStream 함수에서 1초 간격으로 숫자를 생성하면서 Stream으로 전달합니다.

sumStream 함수에서 Stream의 각 숫자를 받아서 합계를 계산하고 출력합니다.

모든 숫자가 처리되면 최종 합계를 반환하고 출력합니다.

stream 객체의 문자열 표현을 출력합니다.

1. countStream 함수:

•

1부터 입력받은 숫자까지 1초 간격으로 숫자를 생성하는 Stream을 생성합니다.

•

async* 키워드를 사용하여 비동기 생성기 함수로 정의합니다.

•

for 반복문에서 1부터 to까지 숫자를 반복합니다.

•

Future.delayed를 사용하여 1초 지연을 시뮬레이션합니다.

•

yield 키워드를 사용하여 각 숫자를 Stream으로 전달합니다.

2. sumStream 함수:

•

Stream을 전달받아서 합계를 계산하는 함수입니다.

•

async 키워드를 사용하여 비동기 함수로 정의합니다.

•

sum 변수를 0으로 초기화합니다.

•

await for 키워드를 사용하여 Stream의 각 값을 순회합니다.

•

각 값을 sum에 더하고, 현재 값과 합계 값을 출력합니다.

•

최종 합계를 반환합니다.

3. main 함수:

•

countStream 함수를 호출하여 1부터 10까지의 숫자를 생성하는 Stream을 생성합니다.

•

sumStream 함수를 호출하여 Stream의 합계를 계산합니다.

•

"요청중..." 메시지를 출력합니다.

•

계산된 합계를 출력합니다.

•

stream을 출력합니다. (stream 객체의 문자열 표현을 출력합니다.)

출력 결과

합계
요청 : 1
전달된 값 : 1 - sum : 1
요청 : 2
전달된 값 : 2 - sum : 3
...
요청 : 10
전달된 값 : 10 - sum : 55
요청중...
55
Dart
복사