dwds/lib/src/utilities/synchronized.dart

// Copyright (c) 2023, the Dart project authors.  Please see the AUTHORS file
// for details. All rights reserved. Use of this source code is governed by a
// BSD-style license that can be found in the LICENSE file.

import 'dart:async';

import 'package:pool/pool.dart';

class AtomicQueue {
  final _pool = Pool(1);

  AtomicQueue();

  // Executes tasks sequentially.
  Future<T> run<T>(FutureOr<T> Function() task) => _pool.withResource(task);
}