Function task

src/pkg/utils/concurrency-control.test.ts:47–55

()

    let maxConcurrent = 0;

    const task = async () => {
      await sem.acquire();
      concurrent++;
      maxConcurrent = Math.max(maxConcurrent, concurrent);
      // 模拟异步操作
      await new Promise((r) => setTimeout(r, 10));
      concurrent--;
      sem.release();
    };

    await Promise.all(Array.from({ length: 10 }, () => task()));