帮我写一个dart的线程池工具类

好的，以下是一个简单的 Dart 线程池工具类的示例代码：

import 'dart:collection';
import 'dart:async';

class ThreadPool {
  int _maxThreads;
  Queue<Function> _workQueue = Queue<Function>();
  List<Worker> _workers = [];

  ThreadPool(this._maxThreads) {
    for (int i = 0; i < _maxThreads; i++) {
      _workers.add(Worker(_workQueue));
    }
  }

  Future execute(Function task) async {
    Completer completer = Completer();
    _workQueue.add(() async {
      await task();
      completer.complete();
    });
    return completer.future;
  }

  void shutdown() {
    _workers.forEach((worker) => worker.stop());
  }
}

class Worker {
  final Queue<Function> _workQueue;
  bool _isRunning = true;

  Worker(this._workQueue) {
    _start();
  }

  void _start() async {
    while (_isRunning) {
      if (_workQueue.isNotEmpty) {
        var task = _workQueue.removeFirst();
        await task();
      } else {
        await Future.delayed(Duration(milliseconds: 100));
      }
    }
  }

  void stop() {
    _isRunning = false;
  }
}

使用示例：

void main() async {
  var threadPool = ThreadPool(2);

  await threadPool.execute(() async {
    print('Task 1 started');
    await Future.delayed(Duration(seconds: 2));
    print('Task 1 completed');
  });

  await threadPool.execute(() async {
    print('Task 2 started');
    await Future.delayed(Duration(seconds: 1));
    print('Task 2 completed');
  });

  await threadPool.execute(() async {
    print('Task 3 started');
    await Future.delayed(Duration(seconds: 3));
    print('Task 3 completed');
  });

  threadPool.shutdown();
}

这个示例代码中，我们首先定义了一个 `ThreadPool` 类，它包含了一个任务队列 `_workQueue` 和一个线程池 `_workers`。在构造函数中，我们初始化了 `_workers` 数组并创建了若干个 `Worker` 实例，每个 `Worker` 实例都会从 `_workQueue` 中取出任务并执行。

`execute` 方法用于添加任务到队列中，它会返回一个 `Future` 对象，用于等待任务执行完成。

`Worker` 类是一个内部类，用于表示线程池中的一个工作者。它会持续地从任务队列中取出任务并执行，直到线程池被关闭。