如何在dart中实现多个并发工作进程( async )的异步任务队列

import 'dart:isolate';

ReceivePort receivePort = ReceivePort();

List<Isolate> isolates = [];

void workerEntry(SendPort sendPort) {
  // 接收来自主进程的消息
  receivePort.listen((message) {
    // 执行异步任务
    // ...

    // 将结果发送回主进程
    sendPort.send(result);
  });
}

int numWorkers = 4; // 设置工作进程的数量

for (int i = 0; i < numWorkers; i++) {
  Isolate.spawn(workerEntry, receivePort.sendPort);
}

Future<void> runTask(dynamic task) async {
  Completer completer = Completer();

  // 创建一个发送端口来接收工作进程的结果
  ReceivePort resultPort = ReceivePort();

  // 监听结果并完成Future
  resultPort.listen((result) {
    completer.complete(result);
    resultPort.close();
  });

  // 随机选择一个工作进程发送任务
  int workerIndex = Random().nextInt(numWorkers);
  isolates[workerIndex].send(task, resultPort.sendPort);

  return completer.future;
}

List<dynamic> tasks = [task1, task2, task3]; // 要执行的任务列表

List<Future<dynamic>> futures = [];

for (dynamic task in tasks) {
  futures.add(runTask(task));
}

// 等待所有任务完成
await Future.wait(futures);