我们知道在flutter中可以通过Future.wait,来进行异步并发请求,并且在所有异步任务执行完后,再进行后续代码的执行,但是问题在于Future.wait会将异步任务同时发起,将会产生可能意想不到的问题,比如在异步函数中,通过channel调用原生函数,原生函数需要创建线程来完成,这时大量的线程创建是否会对app制造压力,所以想着是否可以控制最大并发数量,就像是iOS原生中的信号量来控制最大并发呢
其实这里可以简单的先理清一下需求,就是一个任务执行完后检查一下是否还有任务,如果有,并且不超过要求的最大的并发量,就执行
所以这里不可以像Future.wait一样将Future传进来,而应该是Future Function(),并且需要设置最大的并发量

static Future test(List<Future Function()> list,{int maxAsyncCount = 10}) async {
}

• 下一步需要考虑的是如何监听任务执行完毕,我这里用到ValueNotifier,来监听当前任务执行的数量

static Future test(List<Future Function()> list,{int maxAsyncCount = 10}) async {
  ValueNotifier doingCount = ValueNotifier(0);
}

• 接下来需要监听这个notifier

static Future wait(List<Future Function()> list,{int maxAsyncCount = 10}) async {
  ValueNotifier doingCount = ValueNotifier(0);
  doingCount.addListener(() {
      if (doingCount.value < maxAsyncCount && list.isNotEmpty) {
        doTask(list.first);
        doingCount.value++;
      }
   });
}

这里封装了执行任务的方法

doTask(Future Function() task) async {
      list.remove(task);
      await task();
      doingCount.value--;
}

作为wait内部函数,这样可以获取到list和doingCount

static Future wait(List<Future Function()> list,{int maxAsyncCount = 10}) async {
  ValueNotifier doingCount = ValueNotifier(0);
  doTask(Future Function() task) async {
      list.remove(task);
      await task();
      doingCount.value--;
  }
  doingCount.addListener(() {
      if (doingCount.value < maxAsyncCount && list.isNotEmpty) {
        doTask(list.first);
        doingCount.value++;
      }
   });
}

每当有新任务执行,doingCount进行+1操作,每当有任务执行完成进行-1操作

• 最后一步是所有任务执行完成后返回,用到了Completer,再所有任务开始执行前进行等待future,当最后一个任务执行完成后调用complete

static Future wait(List<Future Function()> list,{int maxAsyncCount = 10}) async {
    if (list.isEmpty) return;

    ValueNotifier doingCount = ValueNotifier(0);
    Completer completer = Completer();

    doTask(Future Function() task) async {
      list.remove(task);
      await task();
      doingCount.value--;

    }
    doingCount.addListener(() {
      if (doingCount.value < maxAsyncCount && list.isNotEmpty) {
        doTask(list.first);
        doingCount.value++;
      } else if (doingCount.value == 0) {
        completer.complete();
      }
    });

    doTask(list.first);
    doingCount.value++;

    await completer.future;
}

这里需要手动去出发第一个任务的执行
到这里基本的功能就实现了,我们可以进行一个简单的测试

final date = DateTime.now();
AsyncCountFuture.wait(
   List.generate(10, (index) {
      return () async {
         await Future.delayed(Duration(seconds: index % 2 == 0 ? 1 : 4));
         print("$index 延迟${(DateTime.now().millisecondsSinceEpoch - date.millisecondsSinceEpoch)~/1000}秒执行");
      };
   }),
   maxAsyncCount: 5,
).then((value) {
   print("执行完毕");
});

打印结果

flutter: 0 延迟1秒执行
flutter: 2 延迟1秒执行
flutter: 4 延迟1秒执行
flutter: 6 延迟2秒执行
flutter: 8 延迟3秒执行
flutter: 1 延迟4秒执行
flutter: 3 延迟4秒执行
flutter: 5 延迟5秒执行
flutter: 7 延迟5秒执行
flutter: 9 延迟7秒执行
flutter: 执行完毕

perfect,确实是我们想要的结果
但是还存在一个问题,就是入参的Future Function()被定义死了,这个地方我优化的方案,借鉴了ListView,builder的方式,提供了itemCount,和itemBuilder,将Future函数的执行放到业务端来处理

static Future waitBuilder({
    required int itemCount,
    required FutureCallback itemBuilder,
    int maxAsyncCount = 10,
}) async {
    if (itemCount == 0) return;

    ValueNotifier doingCount = ValueNotifier(0);
    int nextIndex = 0;
    Completer completer = Completer();

    doTask(int index) async {
      nextIndex++;
      await itemBuilder(index);
      doingCount.value--;
    }

    doingCount.addListener(() {
      if (doingCount.value < maxAsyncCount && nextIndex < itemCount) {
        doTask(nextIndex);
        doingCount.value++;
      } else if (doingCount.value == 0) {
        completer.complete();
      }
    });

    doTask(nextIndex);
    doingCount.value++;

    await completer.future;
}

这样,业务上要执行什么异步任务业务可以自己说了算,例如:

test() {
  List<Map> dataList = List.generate(10, (index) {
    return {"name":"$index号","age":"${index+20}","second":index%2 == 0?1:4};
  });
  AsyncCountFuture.waitBuilder(
    itemCount: 10,
    itemBuilder: (index) async {
      final item = dataList[index];
      if (index%2 == 0) {
        await asyncTask1(item["name"], item["age"], item["second"]);
      } else {
        await asyncTask2(item["name"], item["second"]);
      }
    },
    maxAsyncCount: 5,
  ).then((value) {
    print("执行完毕");
  });
}

asyncTask1(String name,String age,int second) async {
    await Future.delayed(Duration(seconds: second));
    print("task1 --- $name 年龄: $age");
}
asyncTask2(String name,int second) async {
    await Future.delayed(Duration(seconds: second));
    print("task2 --- $name 年龄未知");
}

完毕!