【Flutter/Dart】Futureで非同期処理の実装方法！await/asyncの使い方

/// 時間のかからない処理
Future<String> fetchDataNotAsync() {
  return Future.value('データ取得完了');
}

// 時間のかかる処理
Future<String> fetchData() async {
  // 疑似的に2秒待機
  await Future.delayed(Duration(seconds: 2));
  return 'データ取得完了';
}

void main() async {
  print('START');
  // 結果を取得できるまで待機
  String result = await fetchData();
  print(result);
  print('END');
}
// 出力
START
データ取得完了 // 2秒後
END

Future<String> fetchDataError() async {
  throw Exception('データ取得に失敗しました');
  // または以下
  // return Future.error('不明なエラー');
}

void main() async {
  print('START');
  try {
    String result = await fetchDataError();
    // エラーになると以下は呼ばれない
    print(result);
  } catch (e) {
    print('エラー発生: $e');
  }
  print('END');
}

void main() {
  print('START');
  fetchData().then((value) {
    print('Success: $value');
  });
  print('END');
}

// 出力
START
END
Success: データ取得完了 // 2秒後

Future<int> calc() {
  return Future.delayed(Duration(seconds: 1), () => 10);
}

void main() {
  calc()
    .then((value) => value * 2)
    .then((result) => print('結果: $result')); // 結果: 20
}

Future<String> fetchError() {
  return Future.error('エラー発生');
}

void main() {
  fetchError()
      .then((value) => print('成功: $value'))
      .catchError((e) => print('失敗: $e'));
}

void main() async {
  final results = await Future.wait([
    // 遅延処理1
    Future.delayed(Duration(seconds: 1), () => 'A'),
    // 遅延処理2
    Future.delayed(Duration(seconds: 4), () => 'B'),
  ]);
  // 上記の場合4秒後に以下の結果を取得できる
  print(results); // ['A', 'B']
}

void main() async {
  await Future.forEach([1, 2, 3], (num) async {
    await Future.delayed(Duration(seconds: 1));
    print('処理: $num');
  });
}

// 1秒遅延
await Future.delayed(Duration(seconds: 1));
// 500ミリ秒遅延
await Future.delayed(Duration(milliseconds: 500));
// 1秒遅延後に任意の処理を実行
final result = await Future.delayed(
  Duration(seconds: 1),
  () => '完了データ',
);

Future<String> fetchData() async {
  await Future.delayed(Duration(seconds: 3));
  return 'データ取得完了';
}

void main() async {
  try {
    final result = await fetchData().timeout(Duration(seconds: 2));
    print(result);
  } catch (e) {
    // TimeoutException after 0:00:02.000000: Future not completed
    print('タイムアウト: $e');
  }
}

/// 最新の記事を取得する
Future<List<QiitaItem>> fetchLatestItems(
    {int page = 1, int perPage = 10}) async {
  try {
    final response = await apiService.get(
        '/items?page=$page&per_page=$perPage');
    if (response.statusCode == 200) {
      final List<dynamic> jsonList = jsonDecode(response.body);
      return jsonList.map((e) => QiitaItem.fromJson(e)).toList();
    } else {
      throw Exception('通信失敗: ${response.statusCode}');
    }
  } catch (e) {
    throw Exception('例外: $e');
  }
}

FutureBuilder<List<QiitaItem>>(
  future: repository.fetchLatestItems(),
  builder: (context, snapshot) {

    // 通信中
    if (snapshot.connectionState == ConnectionState.waiting) {
      return Center(child: CircularProgressIndicator());
    }

    // エラーが出たら表示
    if (snapshot.hasError) {
      return Center(child: Text('エラー: ${snapshot.error}'));
    }


    // データがない場合
    if (!snapshot.hasData || snapshot.data!.isEmpty) {
      return const Center(child: Text('データが見つかりません'));
    }

    final items = snapshot.data!;
    return ListView.builder(
      itemCount: items.length,
      itemBuilder: (_, index) {
        final item = items[index];
        return ListTile(
          title: Text(item.title),
          subtitle: Text('投稿者: ${item.userId}'),
        );
      },
    );
  },
)