C#多线程的几种方法详解示例(上)

简介: C#多线程的几种方法详解示例

这里主要介绍了c#使用多线程的几种方式,通过示例学习c#的多线程使用方式,大家参考使用吧!

1 进程、线程、同步、异步的概念

2 回顾委托,开始异步

3 异步多线程的三大特点


异步多线程都觉得很厉害,也是面试必备,高级开发必备技能

多线程很熟悉/经常在用的 ?

多线程在用,但是很懵 ?

一直没怎么敢用的 ?


多线程在.Net不同的版本里面,都在不断的升级

单进程多线程的模型


进程:计算机概念,把程序运行时占用的全部计算资源,叫做进程

线程:计算机概念,程序执行的最小单位,包含自己使用的各种计算资源

多线程:计算机概念,多个线程同时执行(上传画面/声音上传/获取聊天消息)

一个进程可以包含多个线程,线程是隶属于进程的


C#是面向对象语言,万物皆对象,类来映射现实生活中的物体

Thread就是线程类

多个Thread并发执行,就是多线程

 

委托的异步调用

1 同步方法卡界面,Winform的UI线程在忙于计算,不能响应别的操作

异步多线程方法不卡界面,UI线程闲置,计算任务交给其他线程执行

Winform--点击个按钮不希望界面卡死

Web--写文本日志,发邮件,这正耗时操作其实可以多线程的


2 同步方法慢(14155),只有一个线程计算

异步多线程方法快(5144),多个线程并发计算

一般认为计算机是精准的,5个线程比1个线程 那应该是5倍?

多线程是用资源换性能,

a资源有限(一般来说资源够的) b线程调度管理损耗 性能不是线性增长,

速度快的应用太多了,

有个大表查询很慢,能不能多线程优化下,提升下性能? T/F 不行,任务不能拆分

一个数据库查询,一个接口调用,一个硬盘读写,一个相加计算,可以,任务是独立运行的

但是线程不是越多越好


3 多线程的无序性:

启动无序:线程是计算机资源,线程申请是操作系统调度管理的,随机了!

同一个线程执行同一个任务时间不确定:CPU分片,看运气(线程优先级)

结束无序:以上叠加

这个是提请注意,很多时候多线程操作,但是又有顺序要求,

延迟一下启动? 不靠谱, 线程优先级也不靠谱

也许运行1w次都是对的,但是随着业务的变化 数据量的增加 服务器的升级,执行时间都是会变的

以前运行的好好的,偶尔就错一下,或者数据量大了,总是错

线程顺序的控制,且听下回分解

(0)线程池

 //线程池
    class Thread2
    {
        public void ThreadMain()
        {
            ThreadDemoClass demoClass = new ThreadDemoClass();
            //设置当没有请求时线程池维护的空闲线程数
            //第一个参数为辅助线程数
            //第二个参数为异步 I/O 线程数
            ThreadPool.SetMinThreads(5, 5);
            //设置同时处于活动状态的线程池的线程数,所有大于次数目的请求将保持排队状态,直到线程池变为可用
            //第一个参数为辅助线程数
            //第二个参数为异步 I/O 线程数
            ThreadPool.SetMaxThreads(100, 100);
            //使用委托绑定线程池要执行的方法(无参数)
            WaitCallback waitCallback1 = new WaitCallback(demoClass.Run1);
            //将方法排入队列,在线程池变为可用时执行
            ThreadPool.QueueUserWorkItem(waitCallback1);
            //使用委托绑定线程池要执行的方法(有参数)
            WaitCallback waitCallback2 = new WaitCallback(demoClass.Run1);
            //将方法排入队列,在线程池变为可用时执行
            ThreadPool.QueueUserWorkItem(waitCallback2, "张三");
            UserInfo userInfo = new UserInfo();
            userInfo.Name = "张三";
            userInfo.Age = 33;
            //使用委托绑定线程池要执行的方法(有参数,自定义类型的参数)
            WaitCallback waitCallback3 = new WaitCallback(demoClass.Run2);
            //将方法排入队列,在线程池变为可用时执行
            ThreadPool.QueueUserWorkItem(waitCallback3, userInfo);
            Console.WriteLine();
            Console.WriteLine("主线程正在工作…");
            Console.WriteLine("主线程ID为:" + Thread.CurrentThread.ManagedThreadId.ToString());
            Console.ReadKey();
        }
        //子线程类
        public class ThreadDemoClass
        {
            //子线程1
            public void Run1(object obj)
            {
                string name = obj as string;
                Console.WriteLine();
                Console.WriteLine("子线程正在工作…");
                Console.WriteLine("我的名字是 " + name);
                Console.WriteLine("子线程ID为:" + Thread.CurrentThread.ManagedThreadId.ToString());
            }
            //子线程2
            public void Run2(object obj)
            {
                UserInfo userInfo = (UserInfo)obj;
                Console.WriteLine();
                Console.WriteLine("子线程正在工作…");
                Console.WriteLine("我的名字是 " + userInfo.Name);
                Console.WriteLine("我今年" + userInfo.Age + "岁");
                Console.WriteLine("子线程ID为:" + Thread.CurrentThread.ManagedThreadId.ToString());
            }
        }
        public class UserInfo
        {
            public string Name { get; set; }
            public int Age { get; set; }
        }
    }

(1)不需要传递参数,也不需要返回参数

ThreadStart是一个委托,这个委托的定义为void ThreadStart(),没有参数与返回值。

class Program
{
static void Main(string[] args)
{
for (int i = 0; i < 30; i++)
{
ThreadStart threadStart = new ThreadStart(Calculate);
Thread thread = new Thread(threadStart);
thread.Start();
}
Thread.Sleep(2000);
Console.Read();
}
public static void Calculate()
{
DateTime time = DateTime.Now;//得到当前时间
Random ra = new Random();//随机数对象
Thread.Sleep(ra.Next(10,100));//随机休眠一段时间
Console.WriteLine(time.Minute + ":" + time.Millisecond);
}
}

(2)需要传递单个参数

ParameterThreadStart委托定义为void ParameterizedThreadStart(object state),有一个参数但是没有返回值。

class Program
{
static void Main(string[] args)
{
for (int i = 0; i < 30; i++)
{
ParameterizedThreadStart tStart = new ParameterizedThreadStart(Calculate);
Thread thread = new Thread(tStart);
thread.Start(i*10+10);//传递参数
}
Thread.Sleep(2000);
Console.Read();
}
public static void Calculate(object arg)
{
Random ra = new Random();//随机数对象
Thread.Sleep(ra.Next(10, 100));//随机休眠一段时间
Console.WriteLine(arg);
}
}

(3)使用专门的线程类(常用)

使用线程类可以有多个参数与多个返回值,十分灵活!

class Program
{
static void Main(string[] args)
{
MyThread mt = new MyThread(100);
ThreadStart threadStart = new ThreadStart(mt.Calculate);
Thread thread = new Thread(threadStart);
thread.Start();
   //等待线程结束
while (thread.ThreadState != ThreadState.Stopped)
{
Thread.Sleep(10);
}
Console.WriteLine(mt.Result);//打印返回值
Console.Read();
}
}
public class MyThread//线程类
{
public int Parame { set; get; }//参数
public int Result { set; get; }//返回值
//构造函数
public MyThread(int parame)
{
this.Parame = parame;
}
//线程执行方法
public void Calculate()
{
Random ra = new Random();//随机数对象
Thread.Sleep(ra.Next(10, 100));//随机休眠一段时间
Console.WriteLine(this.Parame);
this.Result = this.Parame * ra.Next(10, 100);
}
}
相关文章
|
1月前
|
JSON 程序员 C#
使用 C# 比较两个对象是否相等的7个方法总结
比较对象是编程中的一项基本技能,在实际业务中经常碰到,比如在ERP系统中,企业的信息非常重要,每一次更新,都需要比较记录更新前后企业的信息,直接比较通常只能告诉我们它们是否指向同一个内存地址,那我们应该怎么办呢?分享 7 个方法给你!
|
1月前
|
C# UED SEO
C# 异步方法async / await任务超时处理
通过使用 `Task.WhenAny`和 `Task.Delay`方法,您可以在C#中有效地实现异步任务的超时处理机制。这种方法允许您在指定时间内等待任务完成,并在任务超时时采取适当的措施,如抛出异常或执行备用操作。希望本文提供的详细解释和代码示例能帮助您在实际项目中更好地处理异步任务超时问题,提升应用程序的可靠性和用户体验。
72 3
|
2月前
|
Java 开发者
在Java多线程编程中,创建线程的方法有两种:继承Thread类和实现Runnable接口
【10月更文挑战第20天】在Java多线程编程中,创建线程的方法有两种:继承Thread类和实现Runnable接口。本文揭示了这两种方式的微妙差异和潜在陷阱,帮助你更好地理解和选择适合项目需求的线程创建方式。
31 3
|
2月前
|
Java 开发者
在Java多线程编程中,选择合适的线程创建方法至关重要
【10月更文挑战第20天】在Java多线程编程中,选择合适的线程创建方法至关重要。本文通过案例分析,探讨了继承Thread类和实现Runnable接口两种方法的优缺点及适用场景,帮助开发者做出明智的选择。
24 2
|
2月前
|
安全 Java
Java多线程通信新解:本文通过生产者-消费者模型案例,深入解析wait()、notify()、notifyAll()方法的实用技巧
【10月更文挑战第20天】Java多线程通信新解:本文通过生产者-消费者模型案例,深入解析wait()、notify()、notifyAll()方法的实用技巧,包括避免在循环外调用wait()、优先使用notifyAll()、确保线程安全及处理InterruptedException等,帮助读者更好地掌握这些方法的应用。
24 1
|
2月前
|
Java 开发者
Java多线程初学者指南:介绍通过继承Thread类与实现Runnable接口两种方式创建线程的方法及其优缺点
【10月更文挑战第20天】Java多线程初学者指南:介绍通过继承Thread类与实现Runnable接口两种方式创建线程的方法及其优缺点,重点解析为何实现Runnable接口更具灵活性、资源共享及易于管理的优势。
46 1
|
2月前
|
Java
在Java多线程编程中,`wait()`和`notify()`方法的相遇如同一场奇妙的邂逅
在Java多线程编程中,`wait()`和`notify()`方法的相遇如同一场奇妙的邂逅。它们用于线程间通信,使线程能够协作完成任务。通过这些方法,生产者和消费者线程可以高效地管理共享资源,确保程序的有序运行。正确使用这些方法需要遵循同步规则,避免虚假唤醒等问题。示例代码展示了如何在生产者-消费者模型中使用`wait()`和`notify()`。
32 1
|
2月前
|
安全 Java 开发者
Java多线程中的`wait()`、`notify()`和`notifyAll()`方法,探讨了它们在实现线程间通信和同步中的关键作用
本文深入解析了Java多线程中的`wait()`、`notify()`和`notifyAll()`方法,探讨了它们在实现线程间通信和同步中的关键作用。通过示例代码展示了如何正确使用这些方法,并分享了最佳实践,帮助开发者避免常见陷阱,提高多线程程序的稳定性和效率。
52 1
|
1月前
|
C# 开发者
C# 一分钟浅谈:Code Contracts 与契约编程
【10月更文挑战第26天】本文介绍了 C# 中的 Code Contracts,这是一个强大的工具,用于通过契约编程增强代码的健壮性和可维护性。文章从基本概念入手,详细讲解了前置条件、后置条件和对象不变量的使用方法,并通过具体代码示例进行了说明。同时,文章还探讨了常见的问题和易错点,如忘记启用静态检查、过度依赖契约和性能影响,并提供了相应的解决建议。希望读者能通过本文更好地理解和应用 Code Contracts。
36 3
|
3天前
|
存储 安全 编译器
学懂C#编程:属性(Property)的概念定义及使用详解
通过深入理解和使用C#的属性,可以编写更清晰、简洁和高效的代码,为开发高质量的应用程序奠定基础。
31 12