详解C#中线程传参,返回值和多线程冲突问题的解决

 更新时间:2022年11月30日 08:19:37   作者:dawn  
这篇文章主要为大家详细介绍了C#中线程传参,返回值和多线程冲突问题的解决方法,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下

在C#中,开启一个线程很容易。

Thread Th1= new Thread(func);
Th1.Start();
 
private void func(object Obj)
{
    //处理代码
}

很多情况下,我们是需要对线程进行传递参数的,这个也简单。

1、线程的单一参数传递

        private void button1_Click(object sender, EventArgs e)
        {
            Thread Th1= new Thread(func);
            Th1.Start("CSDN");
            Thread.Sleep(500);
        }
 
        private void func(object Obj)
        {
            string Str = Obj as string;
            textBox1.BeginInvoke(new Action(() =>
            {
                textBox1.Text = $"传入的参数:{Str}";
            }));
        }

2、线程的多参数传递以及返回值

上面的例子是单一的参数,参数要求是对象,使用的时候进行了拆箱,根据上面的例子对于多参数,可以使用中间对象来处理,就是在中间对象中放置参数和获取处理后的结果。

        private void button1_Click(object sender, EventArgs e)
        {
            FinancialInfo FI=new FinancialInfo();
            FI.PersonName = "CSDN";
            FI.PersonDeposit = 123;
            Thread Th1 = new Thread(FI.ThreadChangeFinanceialInfo);
            Th1.Start();
            Thread.Sleep(500);
            textBox1.Text=FI.PersonName+Environment.NewLine+FI.PersonDeposit.ToString();
        }
 
        private class FinancialInfo
        {
            private string Name=string.Empty;
            private int Deposit=0;
            public string PersonName
            {
                get { return Name; }
                set { Name = value; }
            }
 
            public int PersonDeposit
            {
                get { return Deposit; }
                set { Deposit = value; }
            }
 
            public void ThreadChangeFinanceialInfo() 
            {
                this.Name = this.Name + " | C#";
                this.Deposit = this.Deposit + 100;
            }

3、多线程可能引起的冲突

多线程在处理同一对象时容易引起潜在的冲突,这个显而易见,例如:

        private void button1_Click(object sender, EventArgs e)
        {
            FinancialInfo FI = new FinancialInfo();
            FI.PersonName = "CSDN";
            FI.PersonDeposit = 123;
            Thread Th1 = new Thread(FI.ThreadAdd);
            Thread Th2 = new Thread(FI.ThreadReduce);
            Th1.Start();
            Th2.Start();
            Thread.Sleep(5000);
            textBox1.Text = textBox1.Text + FI.PersonName +"|"+FI.PersonDeposit.ToString()+Environment.NewLine;
        }
 
        private class FinancialInfo
        {
            private string Name=string.Empty;
            private int Deposit=0;
            public string PersonName
            {
                get { return Name; }
                set { Name = value; }
            }
 
            public int PersonDeposit
            {
                get { return Deposit; }
                set { Deposit = value; }
            }
 
            public void ThreadAdd()
            {
                for (int i = 0; i < 1000000; i++)
                {
                    this.Deposit = this.Deposit + 1;
                }
            }
 
            public void ThreadReduce()
            {
                for (int i = 0; i < 1000000; i++)
                {
                    this.Deposit = this.Deposit - 1;
                }
            }
        }

显示结果:

按道理, FI.PersonDeposit的值是123,加了1000000,也减了1000000,那么最终的结果应该还是123,为什么会是这样呢?

这就是多线程在处理同一对象时所产生的冲突了,产生的就是所谓的“脏数据”。

上面的代码因为等待线程执行完,进行了休眠,可以使用Task来写更简单。

            var task1 = new Task(FI.ThreadAdd);
            var task2 = new Task(FI.ThreadReduce);
            task1.Start();
            task2.Start();
 
            Task.WaitAll(task1,task2);

Task是比Thread更加高级的概念,一个Task至少包含一个Thread。

解决上面的冲突就是对可能引起冲突的对象进行加锁判断。

完整代码:

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Drawing.Text;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
 
namespace MultiThread
{
    public partial class Form3 : Form
    {
 
        private static readonly object LockObj=new object();
 
        public Form3()
        {
            InitializeComponent();
        }
 
        private void button1_Click(object sender, EventArgs e)
        {
            FinancialInfo FI = new FinancialInfo();
            FI.PersonName = "CSDN";
            FI.PersonDeposit = 123;
            var task1 = new Task(FI.ThreadAdd);
            var task2 = new Task(FI.ThreadReduce);
            task1.Start();
            task2.Start();
            Task.WaitAll(task1, task2);
            textBox1.Text = textBox1.Text + FI.PersonName +"|"+FI.PersonDeposit.ToString()+Environment.NewLine;
        }
 
 
        private class FinancialInfo
        {
            private string Name=string.Empty;
            private int Deposit=0;
            public string PersonName
            {
                get { return Name; }
                set { Name = value; }
            }
 
            public int PersonDeposit
            {
                get { return Deposit; }
                set { Deposit = value; }
            }
 
            public void ThreadChangeFinanceialInfo() 
            {
                this.Name = this.Name + " | C#";
                this.Deposit = this.Deposit + 100;
            }
 
            public void ThreadAdd()
            {
                for (int i = 0; i < 1000000; i++)
                {
                    lock(LockObj)
                    {
                        this.Deposit = this.Deposit + 1;
                    }                    
                }
            }
 
            public void ThreadReduce()
            {
                for (int i = 0; i < 1000000; i++)
                {
                    lock(LockObj)
                    {
                        this.Deposit = this.Deposit - 1;
                    }                    
                }
            }
        }
    }
}

显示结果:

上面显示出了正确的结果,但是会耗时。

到此这篇关于详解C#中线程传参,返回值和多线程冲突问题的解决的文章就介绍到这了,更多相关C#线程内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • C#多线程系列之工作流实现

    C#多线程系列之工作流实现

    本文详细讲解了C#实现多线程工作流的方法,文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2022-02-02
  • C# 如何实现一个带通知的List<T>

    C# 如何实现一个带通知的List<T>

    这篇文章主要介绍了C# 如何实现一个带通知的List<T>,帮助大家更好的理解和学习使用c#,感兴趣的朋友可以了解下
    2021-02-02
  • C#基础知识之base关键字介绍

    C#基础知识之base关键字介绍

    本文主要介绍base关键字的使用方法,base关键字可以调用基类重写的方法,可以调用基类的构造方法,还可以在EntityFramework中使用,下面一一介绍。
    2016-04-04
  • C#单例模式(Singleton Pattern)详解

    C#单例模式(Singleton Pattern)详解

    这篇文章主要为大家详细介绍了C#单例模式Singleton Pattern的相关资料,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2017-08-08
  • Unity Shader相交算法实现简易防能量盾

    Unity Shader相交算法实现简易防能量盾

    这篇文章主要为大家详细介绍了Unity Shader相交算法实现简易防能量盾,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2020-04-04
  • C# 创建单例的多种方式

    C# 创建单例的多种方式

    这篇文章主要介绍了C# 创建单例的多种方式,帮助大家更好的理解和学习使用c#,感兴趣的朋友可以了解下
    2021-03-03
  • C#代码设置开机启动示例

    C#代码设置开机启动示例

    本文介绍了使用C#代码设置开机启动的方法,原理就是在注册表启动项里添加一项
    2014-01-01
  • C#实现启用与禁用本地网络的方式小结【3种方式】

    C#实现启用与禁用本地网络的方式小结【3种方式】

    这篇文章主要介绍了C#实现启用与禁用本地网络的方式,结合实例形式总结分析了使用Hnetcfg.dll、Shell32.dll及setupapi.dll三种启用与禁用本地网络的操作方法,需要的朋友可以参考下
    2016-07-07
  • C# 批量生成随机密码必须包含数字和字母并用加密算法加密

    C# 批量生成随机密码必须包含数字和字母并用加密算法加密

    这篇文章主要介绍了C# 批量生成随机密码必须包含数字和字母并用加密算法加密,需要的朋友参考下
    2017-01-01
  • WPF数据绑定时出现StringFormat失效的原因和解决方法

    WPF数据绑定时出现StringFormat失效的原因和解决方法

    在数据绑定过程中,我们经常会使用StringFormat对要显示的数据进行格式化,以便获得更为直观的展示效果,但在某些情况下格式化操作并未生效,所以本文介绍了WPF数据绑定时出现StringFormat失效的原因和解决方法,需要的朋友可以参考下
    2024-12-12

最新评论