Bloc事件流是一个阻塞队列结论解析
作者:李小轰_Rex
这篇文章主要为大家介绍了Bloc事件流是一个阻塞队列结论解析,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
前言
在Flutter中有state的概念,我们使用Bloc进行状态管理,通过Bloc.addEvent的方式进行事件传递,状态变更。关于Bloc的基础用法,可以查阅Bloc官网相关资料,这里我们仅记录一下Bloc的队列等待。
新建一个Bloc类
class TestBloc extends Bloc<TestEvent, TestState> { TestBloc() : super(new TestState()); @override Stream<TestState> mapEventToState(TestEvent event) async* { if (event is TestEventA) { print("A"); await Future.delayed(Duration(seconds: 2)); print("finish A await"); } else if (event is TestEventB) { print("B"); } } } abstract class TestEvent {} class TestEventA extends TestEvent {} class TestEventB extends TestEvent {} class TestState {}
如上,定义了一个最基础的Bloc,事件A,事件B。我们接收到事件A后延时等待了2秒钟,用于验证Bloc的Event Loop是否具有阻塞性。
新建一个页面main.dart, 添加按钮事件,同时给bloc发送事件A和事件B:
//...省略非关键代码 onPressed: (){ _bloc.add(TestEventA()); _bloc.add(TestEventB()); }
现象:
print("A") 打印后,等待了2秒,打印 "finish A await", 然后才响应到事件B的触发。
结论:
Bloc 的 event 队列是一个阻塞性队列,先进先出,只有当上一个事件消费完毕后,才会触发响应队列中的下一个事件。
解释开发中所遇到的问题现象
在 await 前面 addEvent,会阻塞线程,造成事件的接收延时,但在await前面 yeild 不受影响,可以在延时前收到状态变更
Stream队列是否也是有序的?
通过代码测试,流内消息体的顺序与加入的顺序无关,与消息体本身的耗时正相关。
以上就是Bloc事件流是一个阻塞队列结论解析的详细内容,更多关于Bloc 事件流阻塞队列的资料请关注脚本之家其它相关文章!