Flutter并发控制插件wait_group的使用

📚 项目概述

wait_group 是一个轻量级的 Dart 实现，灵感来自 Go 语言中的 sync.WaitGroup，用于管理异步任务。

⚙️ 安装

在项目的 pubspec.yaml 文件中添加以下依赖：

dependencies:
  wait_group: ^latest

然后运行以下命令以安装依赖：

flutter pub get

🛠️ 使用示例

以下是完整的使用示例，演示如何使用 WaitGroup 来管理任务、暂停/恢复功能以及重置机制。

示例代码

import 'package:wait_group/wait_group.dart';

void main() async {
  final wg = WaitGroup();

  // 添加三个任务到 WaitGroup 中
  wg.add(3);

  // 任务 1
  Future(() async {
    print('Task 1 started');
    await Future.delayed(Duration(seconds: 2)); // 模拟任务执行
    print('Task 1 completed');
    wg.done(); // 通知任务已完成
  });

  // 任务 2
  Future(() async {
    print('Task 2 started');
    await Future.delayed(Duration(seconds: 3)); // 模拟任务执行
    print('Task 2 completed');
    wg.done(); // 通知任务已完成
  });

  // 任务 3
  Future(() async {
    print('Task 3 started');
    await Future.delayed(Duration(seconds: 1)); // 模拟任务执行
    print('Task 3 completed');
    wg.done(); // 通知任务已完成
  });

  // 暂停 WaitGroup 并在 3 秒后恢复
  Future(() async {
    await Future.delayed(Duration(seconds: 1));
    print('Pausing WaitGroup...');
    wg.pause(); // 暂停任务

    await Future.delayed(Duration(seconds: 3));
    print('Resuming WaitGroup...');
    wg.resume(); // 恢复任务
  });

  // 等待所有任务完成
  print('Waiting for all tasks to complete...');
  await wg.wait(); // 阻塞直到所有任务完成
  print('All tasks completed.');

  // 重置 WaitGroup
  wg.reset();
  print('WaitGroup reset.');
}

输出结果

Task 1 started
Task 2 started
Task 3 started
Pausing WaitGroup...
Task 3 completed
Resuming WaitGroup...
Task 1 completed
Task 2 completed
Waiting for all tasks to complete...
All tasks completed.
WaitGroup reset.