C# 多线程、控制线程数提高循环输出效率-低调大师

C# 多线程、控制线程数提高循环输出效率

2018-05-28 585

C#多线程及控制线程数量，对for循环输出效率。

虽然输出不规律，但是效率明显提高。

思路：

如果要删除1000条数据，只使用for循环，则一个接着一个输出。所以，把1000条数据分成seed段，每段10条数据。

int seed = Convert.ToInt32(createCount.Value) % 10 == 0 ? Convert.ToInt32(createCount.Value) / 10 : Convert.ToInt32(createCount.Value) / 10 + 1;

注：createCount.Value的值是具体输出数据的数量

这里把数据分配给seed个线程去处理，每个线程只输出10个数据。

        int threadCountTmp = 0;//任务线程分派数
        private void btnCreate_Click(object sender, EventArgs e)
        {
            int seed = Convert.ToInt32(createCount.Value) % 10 == 0 ? Convert.ToInt32(createCount.Value) / 10 : Convert.ToInt32(createCount.Value) / 10 + 1;

            for (int i = 0; i < seed; i++)
            {
                Thread threadTmp = new Thread(new ParameterizedThreadStart(TempOut));
                threadTmp.Start(i);
                threadCountTmp++;
                Application.DoEvents();//响应窗口状态
                while (true) { if (threadCountTmp < 10) break; }//推拉窗式控制多线程 线程数10
            }
}
        //分段后的数据发布给其它线程
        public void TempOut(object o)
        {
            int tmp=Convert.ToInt32(o)*10;
            int i = tmp;
            for (; i < (tmp+10<=createCount.Value?tmp+10:createCount.Value); i++)
            {
                Thread thread = new Thread(new ParameterizedThreadStart(ResultOut));
                thread.Start(i);
                threadCount++;
                while (true) { if (threadCount < 10) break; }//推拉窗式控制多线程   线程数10
            }
            threadCountTmp--;
        }

分段后，再将分段后的数据分配给其它线程来处理，这样就能多线程同时工作了，由于要对控件操作，所以使用多线程的话要依靠委托来实现多线程对控件的控制。所以最后一步的输出，如下：

        delegate void TextTmp(object o);//声明委托
        int threadCount = 0;//任务线程
        //委托函数
        public void ResultOut(object o)
        {
            if (!txtResult.InvokeRequired)
            {
                txtResult.Text = "\n" + f_groundcode.Text + "," + f_ticketno.Text + DateTime.Now.ToLongDateString().Replace("-", "") + GetZero(6 - o.ToString().Length) + o.ToString() + "," + DateTime.Now.ToLongDateString().Replace("-", "") + DateTime.Now.ToLongTimeString().Replace(":", "") + txtResult.Text;
            }
            else
            {
                TextTmp tmpDel = new TextTmp(ResultOut);
                this.Invoke(tmpDel,o);
            }
            threadCount--;
        }

因为我的数据要保证位数，所以要对0做简单处理。例如我要输出

000000

000001

000002

000003

........

从上面的代码可以看出，我是使用for来递增的。所以是整型，前面的0随着数值的大小不断改变个数。

        //处理数字前面有多少个0
        private string GetZero(int leng)
        {
            string result = "";
            for (int i = 0; i < leng; i++)
            {
                result += "0";
            }
            return result;
        }

好了。简单的多线程处理。希望大家可以学习。欢迎大家指导~~

微信关注我们

原文链接：https://yq.aliyun.com/articles/678460

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

SpringBoot(四)_Spring Data JPA的使用

JPA 绝对是简化数据库操作的一大利器。概念首先了解 JPA 是什么？ JPA（Java Persistence API）是 Sun 官方提出的 Java 持久化规范。它为 Java 开发人员提供了一种对象/关联映射工具来管理 Java 应用中的关系数据。注意：JPA 是一套规范，不是一套产品，那么像 Hibernate、TopLink、JDO 它们是一套产品，如果说这些产品实现了这个 JPA 规范，那么就可以叫它们为 JPA 的实现产品。实例操作添加依赖 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-jpa</artifactId> </dependency> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</arti...

2018-05-28

605

原文: 监控目前所有连接SQL SERVER的用户信息 if object_id('p_getlinkinfo','P')is not null drop proc p_getlinkinfo go create proc p_getlinkinfo @dbname sysname=null, --要查詢的數據庫名,默認表示所有 @includeip bit=0 --是否顯示IP信息 as begin declare @dbid int set @dbid=db_id(@dbname) if object_id('tempdb..#tb')is not null drop table #tb if object_id('tempdb..#ip')is not null drop table #ip create table #tb (id int identity(1,1), dbname sysname, hostname nchar(128), loginname nchar(128), net_address nchar(12), net_ip nvarchar(15), pro...

2018-05-29

481

资源下载

更多资源

优质分享App

近一个月的开发和优化，本站点的第一个app全新上线。该app采用极致压缩，本体才4.36MB。系统里面做了大量数据访问、缓存优化。方便用户在手机上查看文章。后续会推出HarmonyOS的适配版本。

腾讯云软件源

为解决软件依赖安装时官方源访问速度慢的问题，腾讯云为一些软件搭建了缓存服务。您可以通过使用腾讯云软件源站来提升依赖包的安装速度。为了方便用户自由搭建服务架构，目前腾讯云软件源站支持公网访问和内网访问。

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。