咖啡厅网站开发目标,广告平台网,DW自动生成代码做网站,wordpress get_search_form()1.场景
我们在调用接口时#xff0c;很多时候会同时调用多个接口#xff0c;接口都是异步执行#xff0c;我们很难知道调用的多个接口哪个会最后执行完成#xff0c;我们有时候需要对最后一个接口执行完成的时机监听#xff0c;所以基于该需求#xff0c;设计了CombineE…1.场景
我们在调用接口时很多时候会同时调用多个接口接口都是异步执行我们很难知道调用的多个接口哪个会最后执行完成我们有时候需要对最后一个接口执行完成的时机监听所以基于该需求设计了CombineExecutor对类似的需求进行监听。
2.代码
group_key.dart
///合并执行分类
class GroupKey {///是否需要监听不需要监听则不会执行监听回调final bool isMonitor;GroupKey({this.isMonitor true});
}
executor.dart
import group_key.dart;///执行者
///开始一个无限循环的执行进程等待事件默认50毫秒
class Executor {final GroupKey key;///延迟时间。///进程执行的快慢单位毫秒ms时间越短反应越灵敏///但是消耗的新能越多不能设置为0否则会卡住进程。///默认延迟50ms。final int? delayed;bool _stop true;Function(GroupKey key)? _stopCallback;Function(GroupKey key)? _startCallback;Executor(this.key, {this.delayed});///开始执行[Executor]///[callback]会循环调用start({Function(GroupKey key)? callback}) async {_stop false;_startCallback callback ?? _startCallback;while (!_stop) {_startCallback?.call(key);await Future.delayed(Duration(milliseconds: delayed ?? 50));}_stopCallback?.call(key);}///结束执行[Executor]///[callback]只会在进程结束时执行一次stop({Function(GroupKey key)? callback}) {_stop true;_stopCallback callback ?? _stopCallback;}///是否已启动bool isStart() {return !_stop;}overrideint get hashCode key.hashCode;overridebool operator (Object other) other is! Executor ? false : key other.key;
}
monitor.dart
import package:kq_flutter_widgets/utils/str_util.dart;///合并执行状态持有
class Monitor {dynamic extra;bool _isStart false;bool _isFinish false;bool _isError false;Monitor({this.extra});///该方法接口开始调用时调用Deprecated(只需要监听完成不需要监听开始创建即开始)onStart() {_isStart true;}///该方法接口调用完成时调用onFinish() {_isFinish true;}///该方法接口出错或者请求失败时调用onError() {_isError true;}///该接口是否已开始调用Deprecated(只需要监听完成不需要监听开始创建即开始)bool isStart() {return _isStart;}///该接口是否已完成调用bool isFinish() {return _isFinish;}///该接口是否调用出错bool isError() {return _isError;}///获取额外数据T? getExtraT() {return StrUtil.getValue(extra);}///重置以便复用reset() {_isStart false;_isFinish false;_isError false;}
}str_util.dart
/// 字符串辅助类
class StrUtil {///类型判断static T? getValueT(var value) {if (value null) {return null;} else if (T bool) {return (value 1 || value true || value is bool) as T;} else if (T String) {return value as T;} else if (T int) {return int.parse(value) as T;} else if (T double) {return double.parse(value) as T;} else {return value;}}
}
combine_executor.dart
import package:kq_flutter_widgets/utils/ex/kq_ex.dart;import core/executor.dart;
import core/group_key.dart;
import core/monitor.dart;///合并执行代码主要用到接口调用上
///只监测接口执行过程不涉及接口回调参数等处理。
///以最开始执行的接口开始回调[onStart]方法
///以最后执行完成的接口回调[onFinish]方法。
///当第一个回调开始了并已回调完成了表示整个接口执行完毕
///当第一个接口执行完毕后还没开始执行第二个接口则即使他们有共同的[GroupKey]
///他们也不能在一个处理周期中处理我们把一个同一个[GroupKey]下执行的[onStart]和[onFinish]
///表示一个处理周期。
class CombineExecutor {///执行的对象保存final MapGroupKey, ListMonitor _combines {};///Executor 保存final ListExecutor _executors [];final Function(GroupKey key)? onStart;final Function(GroupKey key)? onFinish;CombineExecutor({this.onStart, this.onFinish});_executor(GroupKey key) {Executor executor Executor(key);if (!_executors.contains(executor)) {_executors.add(executor);onStart?.call(key);executor.start(callback: (key) {ListMonitor combines _getCombines(key);bool flag true;for (Monitor combineMonitor in combines) {if (!combineMonitor.isFinish() !combineMonitor.isError()) {flag false;break;}}//表示最后一个都已执行完成if (flag) {executor.stop(callback: (key) {onFinish?.call(key);_clearCombine(key);_executors.remove(executor);});}});}}///停止在退出界面时调用stop() {for (Executor executor in _executors) {executor.stop();}_executors.clear();_clearAllCombine();}///获取合并执行观察者///设置到请求逻辑中。Monitor getCombine(GroupKey key) {Monitor combineMonitor Monitor();_addCombine(key, combineMonitor);_executor(key);return combineMonitor;}///新增一个CombineMonitor_addCombine(GroupKey key, Monitor combine) {if (key.isMonitor) {if (_combines.containsKey(key)) {ListMonitor? combines _combines[key];combines ?? [];if (!combines.contains(combine)) {combines.add(combine);}} else {_combines.putIfAbsent(key, () [combine]);}}}ListMonitor _getCombines(GroupKey key) {if (_isEmptyCombine(key)) {return [];} else {return _combines[key]!;}}///CombineMonitor是否为空_isEmptyCombine(GroupKey key) {return !_combines.containsKey(key) || _combines[key].isNullOrEmpty;}_clearCombine(GroupKey key) {_combines.remove(key);}///清除全部的CombineMonitor_clearAllCombine() {_combines.clear();}
}///测试
class Test {test() {///创建一个GroupKey改key可用于一组需要调用的接口上GroupKey groupKey GroupKey();///创建对象CombineExecutor executor CombineExecutor(onStart: (key) {///print(执行了onStart);},onFinish: (key) {if (key groupKey) {///print(执行了onFinish);}},);///获取CombineMonitor 传入到接口调用中Monitor monitor executor.getCombine(groupKey);///模拟异步对Monitor进行操作Future.delayed(const Duration(seconds: 2), () {monitor.onFinish();});///退出界面executor.stop();}
}3.使用
