acquire method
获取信号量
Implementation
Future<void> acquire() async {
if (_active < maxConcurrent) {
_active++;
return;
}
final completer = Completer<void>();
_waiters.add(completer);
await completer.future;
}
获取信号量
Future<void> acquire() async {
if (_active < maxConcurrent) {
_active++;
return;
}
final completer = Completer<void>();
_waiters.add(completer);
await completer.future;
}