具有动态延迟的 C# 任务

Question

我有一个函数需要一次处理项目 3，如果总时间少于 x 秒，线程应该在继续处理之前休眠剩余的秒数。

所以我正在做以下事情:

    private void ProcessItems()
    {
        for (int i = 0, n = items.Count; i < n; i++)
        {
            Stopwatch stopwatch = new Stopwatch();
            stopwatch.Start();

            batch.Add(items[i]);

            if (batch.Count == 3 || i >= items.Count - 3)
            {
                List<Task> tasks = new List<Task>(3);

                foreach (Item item in batch)
                    tasks.Add(Task.Factory.StartNew(() => ProcessItem(item)));

                Task.WaitAll(tasks.ToArray());

                batch.Clear();
            }

            stopwatch.Stop();

            int elapsed = (int)stopwatch.ElapsedMilliseconds;
            int delay = (3000) - elapsed;

            if (delay > 0)
                Thread.Sleep(delay);
        }
    }

ProcessItem 函数发出网络请求并处理响应(回调)。这是需要少量时间的功能。

但是，如果我对任务的理解正确的话，一个线程可以有多个任务。因此，如果我休眠该线程，其他任务可能会受到影响。

是否有更有效的方法来实现上述目标，任务是否可以在 Parallel.Foreach 中使用？

Answer 1

任务在自动管理的线程上运行。阻塞线程本质上没有错。只是有点浪费。

下面是我将如何非常干净地实现它:

MyItem[] items = ...;
foreach(MyItem[] itemsChunk in items.AsChunked(3)) {
 Parallel.ForEach(itemsChunk, item => Process(item));
 //here you can insert a delay
}

这不会浪费一个线程，而且非常简单。 Parallel.ForEach 也使用当前线程来处理工作项，因此它不会闲置。您也可以添加延迟逻辑。实现 AsChunked留给读者作为练习...此函数应该将列表拆分为给定大小 (3) 的 block 。这种辅助函数的好处在于，它将批处理逻辑与重要部分分离开来。