Lập trình bất đồng bộ trong Dart/Flutter với futures, async, await
This post hasn't been updated for 5 years
Tại sao cần lập trình bất đồng bộ?
Lập trình bất đồng bộ cho phép chương trình thực hiện công việc trong khi chờ việc khác hoàn thành. Một số ví dụ điển hình như:
- Lấy dữ liệu từ server
- Ghi vào database
- đọc nội dung từ file
Để thực hiện lập trình bất đồng bộ trong Dart/ Flutter thì chúng ta có thể sử dụng Future
và các từ khóa async
và await
.
Future là gì?
Future là kết quả của hoạt động bất đồng bộ và có 2 trạng thái là chưa hoàn thánh và hoàn thành:
-
Chưa hoàn thành: khi chúng ta gọi một hoạt động bất đồng bộ, no sẽ trả về một Future chưa hoàn thành, đây trạng thái của future trước khi trả về kết quả.
-
Hoàn thành: khi hoạt động bất đồng bộ thực hiện xong thì future sẽ ở trạng thái hoàn thành, future có thể hoàn thành với một giá trị hoặc là một lỗi.
Future hoàn thành với một giá trị thì nó có thể là Future<T>
với giá trị có kiểu T, Future<String>
với giá trị kiểu String hoặc là một giá trị void với Future<void>
.
Future hoàn thành với một lỗi khi mà hoạt động bất dồng bộ bị thất bại vì một lí do nào đó.
Sử dụng Future, async, await
Future doEmptyFuture() {}
Future<bool> doSomething() {}
Future<Movie> getMovie()
Bạn có thể sử dụng từ khóa async
trước thân hàm để đánh dấu nó là bất đồng bộ.
Để lấy dữ liệu từ Future chúng ta có thể dùng await
, tuy nhiên await
phải đặt trong async
.
Toàn bộ code trong hàm async
sẽ chạy đồng bộ ngay lập tức đến khi gặp await
và chờ kết quả của future
sau await
.
MaterialButton(
onPressed: () async {
var movie = await getMovie();
}
)
Đôi khi bạn không muốn biến function thành một future hay là điền async
, thì chúng ta có thể sử dụng một cách khác đó là hàm .then()
doSomething().then((value) {
// run completed code here
});
Xử lý lỗi
Khi bạn dùng hàm .then()
thì bạn có thể thêm onError
để xử lý lỗi
doSomething().then((value) {
// run completed code here
}, onError (error) {
// handle error
});
Nếu bạn muốn bắt cụ thể lỗi thì bạn có thể dùng hàm .catchError()
doSomething().then((value) {
// run completed code here
})
.catchError( (error) {
// handle error
});
Để trả về lỗi thì bạn có thể return Future.error
hoặc bạn chỉ cần throw một exception.
Future<bool> myTypedFuture() async {
await Future.delayed(Duration(seconds: 1));
throw Exception('Error from Exception');
}
Bạn cũng có thể kết hợp await
và .catchError
Future runMyFuture() async {
var value = await myTypedFuture()
.catchError((error) {
print(error);
});
}
Quản lý nhiều future cùng lúc
Ví dụ bạn có màn hình cần tải nhiều dữ liệu trước khi làm tiếp một công việc. Bạn sẽ cần phải chờ tất cả future đó hoàn thành. Future có một hàm .wait()
nhận vào list future và trả về một future duy nhất khi tất cả future trong list hoàn thành. Tương tự với zip()
trong rxjava.
Future.wait()
trả về kiểu Future<List<T>>
là một future có type value là list các giá trị T của các future mà nó nhận vào.
// ui to call futures
FlatButton(
child: Text('Run Future'),
onPressed: () async {
await runMultipleFutures();
},
)
// Future to run
Future<bool> myTypedFuture(int id, int duration) async {
await Future.delayed(Duration(seconds: duration));
print('Delay complete for Future $id');
return true;
}
// Running multiple futures
Future runMultipleFutures() async {
// Create list of multiple futures
var futures = List<Future>();
for(int i = 0; i < 10; i++) {
futures.add(myTypedFuture(i, Random(i).nextInt(10)));
}
// Waif for all futures to complete
await Future.wait(futures);
// We're done with all futures execution
print('All the futures has completed');
}
Và dưới đây là output
I/flutter (12116): Delay complete for Future 7
I/flutter (12116): Delay complete for Future 3
I/flutter (12116): Delay complete for Future 9
I/flutter (12116): Delay complete for Future 4
I/flutter (12116): Delay complete for Future 2
I/flutter (12116): Delay complete for Future 1
I/flutter (12116): Delay complete for Future 8
I/flutter (12116): Delay complete for Future 0
I/flutter (12116): Delay complete for Future 6
I/flutter (12116): Delay complete for Future 5
I/flutter (12116): All the futures has completed
Timeouts
Đôi khi hoạt động bất đồng bộ quá lâu và bạn không biết đến bao giờ nó mới dừng thì bạn sẽ muốn thêm thời giạn tối đa cho hoạt động đó thì bạn có thể sử dụng hàm .timeout()
Future<bool> myTypedFuture(int id, int duration) async {
await Future.delayed(Duration(seconds: duration));
print('Delay complete for Future $id');
return true;
}
Future runTimeout() async {
await myTypedFuture(0, 10)
.timeout(Duration(seconds: 2), onTimeout: (){
print('0 timed out');
return false;
});
}
whenComplete
Future còn một hàm khác đó là .whenComplete()
, bạn có thể dùng hàm này để thực hiện code khi mà future hoàn thành.
Bài tuần này đến đây là hết, hẹn gặp lại các bạn trong các bài tiếp theo.
Tham khảo
https://dart.dev/codelabs/async-await
https://medium.com/flutter-community/a-guide-to-using-futures-in-flutter-for-beginners-ebeddfbfb967
All Rights Reserved