具有动态延迟的C#任务

我有一个函数,需要一次处理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中使用任务吗？

解决方法:

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

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

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)的块.这种辅助功能的好处是,它使批处理逻辑与重要部分脱离了关系.

标签：async-await,parallel-processing,task,c
来源： https://codeday.me/bug/20191122/2061367.html