3

дорогие разработчики. Уже на протяжение нескольких дней не могу понять как правильно использовать: Futures, Streams и Async/Await. Я просмотрел видео на официальном канале, но в итоге ничего не смог понять. Было бы круто, если кто-то смог мне это объяснить. Потому что я часто задаю вопросы с использованием этих классов и функций, но не понимаю как они работают. Спасибо за понимание))

1 ответ 1

14

Длительные задачи распространены в мобильных приложениях. В Flutter/Dart это решается с помощью Future. Future позволяет вам выполнять работу асинхронно (Async/Await), чтобы освободить любые другие потоки (Streams), которые не должны быть заблокированы. Например: поток пользовательского интерфейса (UI). Что важно:

  • Код в Dart работает в одном треде (прим. thread — поток) выполнения.
  • Из-за кода, который долго занимает (блокирует) тред выполнения, программа может зависнуть.
  • Объекты Future (futures) представляют результаты асинхронных операций — обработки или ввода-вывода, которые будут завершены позже.
  • Чтобы приостановить выполнение до завершения в будущем, используйте await в асинхронной функции (или then() при использовании Future API).
  • Чтобы поймать ошибки, используйте в асинхронной функции конструкцию try-catch (или catchError() при использовании Future API).

Async/Await

Async/Await

Асинхронное программирование - это форма параллельного выполнения, которая ускоряет цепочку событий в цикле программирования. Однако вы не можем использовать асинхронное программирование во всех случаях. Это работает только в тех случаях, когда вы ищете простоту, а не эффективность. Для обработки простых и независимых данных асинхронное программирование является отличным выбором.

Пример:

import 'package:http/http.dart' as http;

void main() async {
  var response = await http.get('http://google.com'); 
  ... // Наш поток не будет заблокирован, можно выполнять другой код...
  print(response.body); // Как только мы получим ответ мы его отобразим
}

Future

Future представляет собой результат асинхронной операции и может иметь два состояния: незавершенное или завершенное. Так как асинхронные операции могут возвращать исключения, их необходимо обрабатывать. Для этого мы можем использовать следующие методы:

Пример:

import 'dart:async';

const news = '<gathered news goes here>';
const moreSecond = Duration(seconds: 120);

Future<void> printDailyNewsDigest() => gatherNewsReports().then(print).catchError(handleError); // Запрашиваем новости, если они приходят отображаем их, если нет обрабатываем ошибку

Future<String> gatherNewsReports() => Future.delayed(moreSecond, () => news); // Получаем новости через 2 минуты (Например через API)

main() {
  printDailyNewsDigest(); // асинхронный метод
  printWinningLotteryNumbers(); // синхронный метод
  printWeatherForecast(); // синхронный метод
  printBaseballScore(); // синхронный метод
}

printWinningLotteryNumbers() {
  print('Winning lotto numbers: [23, 63, 87, 26, 2]');
}

printWeatherForecast() {
  print("Tomorrow's forecast: 70F, sunny.");
}

printBaseballScore() {
  print('Baseball score: Red Sox 10, Yankees 0');
}

Вывод программы:

Winning lotto numbers: [23, 63, 87, 26, 2] 
Tomorrow's forecast: 70F,sunny. 
Baseball score: Red Sox 10, Yankees 0 
<gathered news goes here>

Streams

Stream

Stream - это последовательность асинхронных событий. Это похоже на асинхронный итерируемый объект (Iterable) - где вместо получения следующего события, когда вы запрашиваете его. Stream сообщает вам, что есть событие, когда он будет готов. Существует два типа потоков: потоки-подписки (single subscription) и широковещательные (broadcast).

Данные метод берет свои корни из реактивного программирования (ReactiveX), и достаточно сложна в изучении новичкам. Если по простому, все что попадет в поток данных, и будет изменяться внутри него, также мгновенно будет изменяться и в других местах где оно используется. Чтобы больше разобраться с этой темой рекомендую прочитать данную статью.

Пример:

import 'dart:async';
import 'package:flutter/material.dart';

class CounterPage extends StatefulWidget {
  @override
  _CounterPageState createState() => _CounterPageState();
}

class _CounterPageState extends State<CounterPage> {
  int _counter = 0;
  final StreamController<int> _streamController = StreamController<int>(); // Наш поток

  @override
  void dispose(){
    _streamController.close(); // Закрываем поток
    super.dispose();
  }

  @override
  Widget build(BuildContext context) {
    return Scaffold(
      appBar: AppBar(title: Text('Stream version of the Counter App')),
      body: Center(
        child: StreamBuilder<int>(
          stream: _streamController.stream, // Создаем и открываем поток
          initialData: _counter, // Наши данные из потока
          builder: (BuildContext context, AsyncSnapshot<int> snapshot){
            return Text('You hit me: ${snapshot.data} times'); // С помощью StreamBuilder получаем асинхронно данные из потока
          }
        ),
      ),
      floatingActionButton: FloatingActionButton(
        child: const Icon(Icons.add),
        onPressed: (){
          _streamController.sink.add(++_counter); // Изменяем данные в потоке (+1)
        },
      ),
    );
  }
}

UPD:

Поподробнее можно посмотреть на видео.

2
  • Вот только не смешивайте конкуррентность и параллелизм. Future - это про конкуррентность, выполнение в том же потоке. Isolates - про параллелизм и выполнение в других потоках api.dartlang.org/stable/2.4.1/dart-isolate/Isolate-class.html
    – VAndrJ
    15 авг 2019 в 10:42
  • @VAndrJ да вы правы. Если найдете ещё недочеты, добавьте их пожалуйста.
    – MiT
    15 авг 2019 в 11:19

Ваш ответ

Нажимая на кнопку «Отправить ответ», вы соглашаетесь с нашими пользовательским соглашением, политикой конфиденциальности и политикой о куки

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.