Flutter3.0线程——四步教你如何全方位了解(事件队列)

一、应用场景

• 队列压缩视频
• 队列解密视频
• 队列请求网络
• 等等

二、实现思路

1. 定义一个任务队列taskList [先进先出]
2. 提供添加任务方法
3. 取第一个任务执行
4. 执行完后，从taskList移除
5. 递归获取第一个任务并执行任务
6. 直到taskList为空停止队列任务

三、具体实现

class QueueUtil {
  /// 用map key存储多个QueueUtil单例,目的是隔离多个类型队列任务互不干扰
  /// Use map key to store multiple QueueUtil singletons, the purpose is to isolate multiple types of queue tasks without interfering with each other
  static Map<String, QueueUtil> _instance = Map<String, QueueUtil>();

  static QueueUtil get(String key) {
    if (_instance[key] == null) {
      _instance[key] = QueueUtil._();
    }
    return _instance[key];
  }

  QueueUtil._() {
    /// 初始化代码
  }

  List<_TaskInfo> _taskList = [];
  bool _isTaskRunning = false;
  int _mId = 0;
  bool _isCancelQueue = false;

  Future<_TaskInfo> addTask(Function doSomething) {
    _isCancelQueue = false;
    _mId++;
    _TaskInfo taskInfo = _TaskInfo(_mId, doSomething);

    /// 创建future
    Completer<_TaskInfo> taskCompleter = Completer<_TaskInfo>();

    /// 创建当前任务stream
    StreamController<_TaskInfo> streamController = new StreamController();
    taskInfo.controller = streamController;

    /// 添加到任务队列
    _taskList.add(taskInfo);

    /// 当前任务的stream添加监听
    streamController.stream.listen((_TaskInfo completeTaskInfo) {
      if (completeTaskInfo.id == taskInfo.id) {
        taskCompleter.complete(completeTaskInfo);
        streamController.close();
      }
    });

    /// 触发任务
    _doTask();

    return taskCompleter.future;
  }

  void cancelTask() {
    _taskList = [];
    _isCancelQueue = true;
    _mId = 0;
    _isTaskRunning = false;
  }

  _doTask() async {
    if (_isTaskRunning) return;
    if (_taskList.isEmpty) return;

    /// 取任务
    _TaskInfo taskInfo = _taskList[0];
    _isTaskRunning = true;

    /// 模拟执行任务
    await taskInfo.doSomething?.call();

    taskInfo.controller.sink.add(taskInfo);

    if (_isCancelQueue) return;

    /// 出队列
    _taskList.removeAt(0);
    _isTaskRunning = false;

    /// 递归执行任务
    _doTask();
  }
}

class _TaskInfo {
  int id; // 任务唯一标识
  Function doSomething;
  StreamController<_TaskInfo> controller;

  _TaskInfo(this.id, this.doSomething, {this.controller});
}

四、使用

main() {
      /// 将任务添加到队列
      print("加入队列-net, taskNo: 1");
      QueueUtil.get("net").addTask(() {
        return _doFuture("net", 1);
      });
      print("加入队列-net, taskNo: 2");
      QueueUtil.get("net").addTask(() {
        return _doFuture("net", 2);
      });
      print("加入队列-local, taskNo: 1");
      QueueUtil.get("local").addTask(() {
        return _doFuture("local", 1);
      });
      
      
      
      /// 取消队列任务
      /// QueueUtil.get("net").cancelTask();
}



  Future _doFuture(String queueName, int taskNo) {
    return Future.delayed(Duration(seconds: 2), () {
      print("任务完成  queueName: $queueName, taskNo: $taskNo");
    });
  }


// 执行结果：
I/flutter (26436): 加入队列-net, taskNo: 1
I/flutter (26436): 加入队列-net, taskNo: 2
I/flutter (26436): 加入队列-local, taskNo: 1
------------两秒后--------
I/flutter (26436): 任务完成  queueName: net, taskNo: 1
I/flutter (26436): 任务完成  queueName: local, taskNo: 1
------------两秒后--------
I/flutter (26436): 任务完成  queueName: net, taskNo: 2

上述就是flutter的线程中的；事件队列。我们从应用场景、实现思路、具体实现、到使用、四个方面了解并使用。flutter 知识学习除了文章中flutter线程事件队列一小部分还分别区分了这几大块：Dart语法基础+语法进阶+flutter UI+flutter线程+flutter启动流程+flutter之framework框架+flutter监控学习。

如果你正好在学习flutter，或者准备学习flutter。在学习中遇到不知道该怎么学习。或者不知从哪开始；可以看我总结如下图的学习指南图：

针对flutter，总结出的核心技术学习方法。整理出一套相对应的资料配合学习。

可以看出图中学习思路很清晰，配合资料学习起来比网上杂乱的资料，学习来事半功倍；如有急切想进阶自己技术，跳槽找工作的。可以上面获取，免费，还望多给博主一些点赞+关注；可以多评论互动哟！