具有动态延迟的C#任务

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了具有动态延迟的C#任务，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1358字，纯文字阅读大概需要2分钟。

内容图文

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

内容总结

以上是互联网集市为您收集整理的具有动态延迟的C#任务全部内容，希望文章能够帮你解决具有动态延迟的C#任务所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端