zoukankan      html  css  js  c++  java
  • c# 线程的几种实现方式

    1.匿名线程实时监控,随便写在一个方法内就可以了

     new Thread(() =>
                {
                    while (implement)
                    {
                        try
                        {
                            //方法实现处
    
                            }
                        }
                        catch
                        {
    
                        }
    
                        Thread.Sleep(10);
                    }
                })
                { IsBackground = true }.Start();
    

    2.Thread类的实现方式,在C# .NetFramework刚出的时候就已经存在了,起初刚开始的程序员都使用这种方式,但经历后面几个.NetFramework的版本更新,实现方式变的更多了。

    public void TestThread()
            {
                //这里需要注意的是:在C#中线程是离不开委托的
                //创建了一个线程对象,这里构造函数提供两类,一种不带参数的,一种是带参数的
                Thread thread = new Thread( TestAction);
                //设置线程相关属性
                thread.IsBackground = true;
                thread.Name = "Test";
                //启动线程
                thread.Start();
            }
    
            /// <summary>
            /// 线程执行的方法
            /// </summary>
            private void TestAction()
            {
                //这里实现线程处理的相关业务
                Console.WriteLine($"子线程Thread({Thread.CurrentThread.Name})执行相关业务操作....{Thread.CurrentThread.ManagedThreadId}");
            }
    

    3.ThreadPool 线程池实现

        /// <summary>
        /// ThreadPool 池化线程,避免频繁的申请和释放消耗资源;之前Thread每次都要申请和释放。
        /// </summary>
            public void TestThreadPool()
            {
                //可以设置相关属性
                ThreadPool.SetMinThreads(5,10);
                ThreadPool.SetMaxThreads(6, 10);
     
                //通过线程池自动分配线程执行对应的业务功能
                ThreadPool.QueueUserWorkItem(TestAction);
                 
                 
            }
     
            private void TestAction(object state)
            {
                //这里实现线程处理的相关业务
                Console.WriteLine($"子线程Thread({Thread.CurrentThread.Name})执行相关业务操作....{Thread.CurrentThread.ManagedThreadId}");
            }
     
    

      

    4.Delegate 实现的多线程(这个方法在core内不支持)

    public void TestDelegateThread()
            {
                //定义一个强类型委托, 可以自定义委托
                Action action = TestAction;
    
                //开始异步操作,其实内部是开启了子线程,看线程id不一样就明白了
                IAsyncResult asyncResult = action.BeginInvoke(CallBack, null);
    
                //可以根据返回对象的一些属性和方法进行判断和业务逻辑执行  具体可以查看相关文档
                //asyncResult.IsCompleted; //判读是否执行完成
                //asyncResult.AsyncWaitHandle.WaitOne(); //阻塞当前线程,直到收到信号量
            }
    
            private void TestAction()
            {
                //这里实现线程处理的相关业务
                Console.WriteLine($"子线程Thread({Thread.CurrentThread.Name})执行相关业务操作....{Thread.CurrentThread.ManagedThreadId}");
            }
    
            /// <summary>
            /// 子线程执行完成时的回调
            /// </summary>
            private void CallBack(IAsyncResult ar)
            {
                Console.WriteLine($"子线程{Thread.CurrentThread.ManagedThreadId}执行完毕");
            }
    

      

    5.BackGroundWorker 实现(比较适用于cs结构)

    BackgroundWorker backgroundWorker = new     BackgroundWorker();
    
            public void TestBackGroundWorker()
            {
                
                //这里使用的是事件的方式绑定业务处理方法
                backgroundWorker.DoWork += TestAction;
    
                //可以绑定一些事件    使用很简单,可以不需要绑定以下事件和设置属性就可以执行,根据需要进行绑定
                //执行完成事件
                backgroundWorker.RunWorkerCompleted += BackgroundWorker_RunWorkerCompleted;
                backgroundWorker.ProgressChanged += BackgroundWorker_ProgressChanged;
                backgroundWorker.WorkerReportsProgress = true;//只有执行这个属性之后才能进行ProgressChanged触发
    
    
                //开始执行操作
                backgroundWorker.RunWorkerAsync();
            }
    
            /// <summary>
            /// 触发事件之后的业务处理
            /// </summary>
            private void BackgroundWorker_ProgressChanged(object sender, ProgressChangedEventArgs e)
            {
                Console.WriteLine("可以在这里更新UI线程上的东西....");
            }
    
            /// <summary>
            /// 触发事件之后的业务处理
            /// </summary>
            private void BackgroundWorker_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)
            {
                Console.WriteLine($"子线程{Thread.CurrentThread.ManagedThreadId}执行完成!!!");
            }
    
            private void TestAction(object sender, DoWorkEventArgs e)
            {
                //这里实现线程处理的相关业务
                Console.WriteLine($"子线程Thread({Thread.CurrentThread.Name})执行相关业务操作....{Thread.CurrentThread.ManagedThreadId}");
                //在业务方法中执行ReportProgress方法会触发ProgressChanged事件
                backgroundWorker.ReportProgress(10);
                Console.WriteLine($"子线程Thread({ Thread.CurrentThread.ManagedThreadId})执行相关业务操作结束");
            }
    

      

    6.Task 实现多线程(市面上经常见到,实践性比较高的线程)

    /// <summary>
            /// Task 实现多线程, 目前为止,Task方式是大家都比较推荐的方式
            /// </summary>
            public void TestTask()
            {
                //创建一个Task实例
                Task task = new Task(TestAction);
                //开始任务
                task.Start();
            }
    
            private void TestAction()
            {
                //这里实现线程处理的相关业务
                Console.WriteLine($"子线程Thread({Thread.CurrentThread.Name})执行相关业务操作....{Thread.CurrentThread.ManagedThreadId}");
            }
    

      

    7.Parallel实现多线程

    /// <summary>
        /// Parallel 是对Task的进一步封装,但会阻塞主线程,主线程会参与业务逻辑处理
        /// </summary>
        public class ParallelImplement
        {
            public void TestParallel()
            {
                //分配线程执行业务逻辑,  Invoke可传多个业务处理,内部会自动分配线程处理
                Parallel.Invoke(TestAction);
            }
            private void TestAction()
            {
                //这里实现线程处理的相关业务
                Console.WriteLine($"子线程Thread({Thread.CurrentThread.Name})执行相关业务操作....{Thread.CurrentThread.ManagedThreadId}");
            }
        }
    

      

     参考:https://www.cnblogs.com/zoe-zyq/p/12166388.html

    勿看他人拿高薪,且看闲时谁在拼

  • 相关阅读:
    记一次模型调试问题:使用TextLSTM/RNN学习不动,损失和acc均无变化
    机器学习常用损失函数
    java多线程使用mdc追踪日志
    搜索笔记整理
    pytorch加载bert模型报错
    Transformer源代码解释之PyTorch篇
    matplotlib画图并设置风格
    PyTorch实现断点继续训练
    通过sklearn使用tf-idf提取英文关键词
    通过依存关系生成邻接矩阵
  • 原文地址:https://www.cnblogs.com/BoKeYuan259/p/13365289.html
Copyright © 2011-2022 走看看