具有动态延迟的C＃任务

Ivan-Mark Debono 发表于 Dev

伊万·马克·德博诺

我有一个函数，一次需要处理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函数进行Web请求并处理响应（回调）。此功能需要少量时间。

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

有没有更有效的方法来实现上述目的，并且可以在Parallel.Foreach中使用任务吗？

usr

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

这是我非常干净地实现此方法的方法：

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）。这样的辅助功能的好处是，它使批处理逻辑与重要部分脱离了关系。

本文收集自互联网，转载请注明来源。

如有侵权，请联系[email protected] 删除。