A股上市公司传智教育(股票代码 003032)旗下技术交流社区北京昌平校区

 找回密码
 加入黑马

QQ登录

只需一步,快速开始

© 何荣智 黑马帝   /  2011-11-6 22:13  /  2246 人查看  /  6 人回复  /   0 人收藏 转载请遵从CC协议 禁止商业使用本文

大家指教啊!!

评分

参与人数 1技术分 +1 收起 理由
杨恩锋 + 1

查看全部评分

6 个回复

倒序浏览
C#程序默认情况下具有一个线程,代码也都是从上至下逐行执行的。 不过,可以创建辅助线程,以便与主线程一起并行执行代码。 这些线程通常称为“辅助线程”。.NET Framework System.Threading 命名空间使线程更易于使用。


创建线程


--------------------------------------------------------------------------------


创建新的 Thread 对象时,将创建新的托管线程。 Thread 类具有接受一个 ThreadStart 委托或 ParameterizedThreadStart 委托的构造函数:该委托包装调用 Start 方法时由新线程调用的方法。 多次调用 Start 将引发 ThreadStateException。



System.Threading.Thread newThread =   new  System.Threading.Thread(AMethod);  

若要开始执行新线程,可使用 Start 方法,

若要停止执行线程,可使用 Abort 方法,

除启动和停止线程之外,还可以通过调用 Sleep方法,当前线程立即阻止,阻止时间的长度等于传递给 Thread.Sleep 的毫秒数 ,

Suspend ()方法挂起线程、使用 Resume 方法继续挂起的线程,(挂起和继续已过时),

以及使用 Abort 方法销毁线程。




1  public static void ThreadProc() 2         { 3             for (int i = 0; true; i++) 4             { 5                 Console.WriteLine("ThreadProc: {0}", i); 6                 Thread.Sleep(0); 7             } 8         } 9 10 11         static void Main(string[] args)12         {13             //主线程开始14              Console.WriteLine("Main thread: Start");15             16             Thread t = new Thread(new ThreadStart(ThreadProc)); 17             18            //辅助线程开始19              t.Start();20 21             //暂停5毫秒22              Thread.Sleep(5);23             for (int i = 0; i < 4; i++)24             {25                 Console.WriteLine("Main thread: Do some work.{0}",i);26                 Thread.Sleep(0);27             }28             //辅助线程结束29              t.Abort();30             Console.ReadLine();ThreadProc()方法看起来是一个死循环,但是当调用t.Abort()方法就会停止辅助线程,从而结束!



简单的传参和回调



1  public  class  Number 2     { 3         private int one; 4         private int two; 5   6  7         private CallbackCalculate callback; 8  9         public Number(int numberOne,int numberTwo,CallbackCalculate callbackDelegate)10         {11             one = numberOne;12             two = numberTwo;13             callback = callbackDelegate;14         }15 16         public  void Calculate()17         {18             Thread.Sleep(10);19             Console.WriteLine(((char)one).ToString()+((char)two).ToString());20             if (callback!=null)21             {22                 callback(one + two);23             }24         }25     }26 27     //回调委托28      public delegate void CallbackCalculate(int result); 29 30 31     class Program32     {33         static void Main(string[] args)34         {35             Number number = new Number(65, 97, new CallbackCalculate(Callback));36 37             Thread t = new Thread(new ThreadStart(number.Calculate));38 39             //表示当前线程是否是后天线程40             t.IsBackground = false;41 42             //当前线程优先级43             t.Priority = ThreadPriority.Highest;44 45             t.Start();46             Console.WriteLine("主线程做一些工作,然后等待");47             //使当前线程一直等到另一线程完成48             t.Join();49             Console.WriteLine("独立的任务已经完成,主线程结束");50             Console.ReadLine();51         }52 53         private  static  void Callback(int  result)54         {55             Console.WriteLine("Main Number:{0}",result);56         }57     }



需要注意的是主线程和创建的辅助线程都默认是前台线程Thread.IsBackground = false;后台线程与前台线程类似,但后台线程不阻止进程停止。 一旦某个进程的所有前台线程都停止,公共语言运行时就会对仍处于活动状态的后台线程调用 Abort 方法,从而结束该进程。




回复 使用道具 举报
C#程序默认情况下具有一个线程,代码也都是从上至下逐行执行的。 不过,可以创建辅助线程,以便与主线程一起并行执行代码。 这些线程通常称为“辅助线程”。.NET Framework System.Threading 命名空间使线程更易于使用。


创建线程


--------------------------------------------------------------------------------


创建新的 Thread 对象时,将创建新的托管线程。 Thread 类具有接受一个 ThreadStart 委托或 ParameterizedThreadStart 委托的构造函数:该委托包装调用 Start 方法时由新线程调用的方法。 多次调用 Start 将引发 ThreadStateException。



System.Threading.Thread newThread =   new  System.Threading.Thread(AMethod);  

若要开始执行新线程,可使用 Start 方法,

若要停止执行线程,可使用 Abort 方法,

除启动和停止线程之外,还可以通过调用 Sleep方法,当前线程立即阻止,阻止时间的长度等于传递给 Thread.Sleep 的毫秒数 ,

Suspend ()方法挂起线程、使用 Resume 方法继续挂起的线程,(挂起和继续已过时),

以及使用 Abort 方法销毁线程。




1  public static void ThreadProc() 2         { 3             for (int i = 0; true; i++) 4             { 5                 Console.WriteLine("ThreadProc: {0}", i); 6                 Thread.Sleep(0); 7             } 8         } 9 10 11         static void Main(string[] args)12         {13             //主线程开始14              Console.WriteLine("Main thread: Start");15             16             Thread t = new Thread(new ThreadStart(ThreadProc)); 17             18            //辅助线程开始19              t.Start();20 21             //暂停5毫秒22              Thread.Sleep(5);23             for (int i = 0; i < 4; i++)24             {25                 Console.WriteLine("Main thread: Do some work.{0}",i);26                 Thread.Sleep(0);27             }28             //辅助线程结束29              t.Abort();30             Console.ReadLine();ThreadProc()方法看起来是一个死循环,但是当调用t.Abort()方法就会停止辅助线程,从而结束!



简单的传参和回调



1  public  class  Number 2     { 3         private int one; 4         private int two; 5   6  7         private CallbackCalculate callback; 8  9         public Number(int numberOne,int numberTwo,CallbackCalculate callbackDelegate)10         {11             one = numberOne;12             two = numberTwo;13             callback = callbackDelegate;14         }15 16         public  void Calculate()17         {18             Thread.Sleep(10);19             Console.WriteLine(((char)one).ToString()+((char)two).ToString());20             if (callback!=null)21             {22                 callback(one + two);23             }24         }25     }26 27     //回调委托28      public delegate void CallbackCalculate(int result); 29 30 31     class Program32     {33         static void Main(string[] args)34         {35             Number number = new Number(65, 97, new CallbackCalculate(Callback));36 37             Thread t = new Thread(new ThreadStart(number.Calculate));38 39             //表示当前线程是否是后天线程40             t.IsBackground = false;41 42             //当前线程优先级43             t.Priority = ThreadPriority.Highest;44 45             t.Start();46             Console.WriteLine("主线程做一些工作,然后等待");47             //使当前线程一直等到另一线程完成48             t.Join();49             Console.WriteLine("独立的任务已经完成,主线程结束");50             Console.ReadLine();51         }52 53         private  static  void Callback(int  result)54         {55             Console.WriteLine("Main Number:{0}",result);56         }57     }



需要注意的是主线程和创建的辅助线程都默认是前台线程Thread.IsBackground = false;后台线程与前台线程类似,但后台线程不阻止进程停止。 一旦某个进程的所有前台线程都停止,公共语言运行时就会对仍处于活动状态的后台线程调用 Abort 方法,从而结束该进程。




回复 使用道具 举报
第一:


     一般来说,直接在子线程中对窗体上的控件操作是会出现异常,这是由于子线程和运行窗体的线程是不

同的空间,因此想要在子线程来操作窗体上的控件,是不可能简单的通过控件对象名来操作,但不是说不能

进行操作,微软提供了Invoke的方法,其作用就是让子线程告诉窗体线程来完成相应的控件操作。


现在用一个用线程控制的进程条来说明,大致的步骤如下:

1. 创建Invoke函数,大致如下:

        /// <summary>

        /// Delegate function to be invoked by main thread

        /// </summary>

        private void InvokeFun()

        {

            if( prgBar.Value < 100 )

                prgBar.Value = prgBar.Value + 1;

        }


2. 子线程入口函数:

        /// <summary>

        /// Thread function interface

        /// </summary>

        private void ThreadFun()

        {

            //Create invoke method by specific function

            MethodInvoker mi = new MethodInvoker( this.InvokeFun );


            for( int i = 0; i < 100; i++ )

            {

                this.BeginInvoke( mi );

                Thread.Sleep( 100 );

            }

        }


3. 创建子线程:

            Thread thdProcess = new Thread( new ThreadStart( ThreadFun ) );

            thdProcess.Start();


       备注:

              using System.Threading;

              private System.Windows.Forms.ProgressBar prgBar;


Control.CheckForIllegalCrossThreadCalls = false; 线程开始的时候加这么一句,OK,看不到错误了~


啥都能用了~

第二:

用委托,在05里,每个控件都有个InvokeRequired的属性~,判断一下是不是true,是的话进行Invoke操作

的,完事了~

//建立个委托
private delegate string returnStrDelegate();

//搞个最简单滴取值滴方法~
private string returnSchool()
        {
            return CB_School.SelectedValue.ToString();
         }

//判断一下是不是该用Invoke滴~,不是就直接返回~
private string returnCB(returnStrDelegate myDelegate)
        {
            if (this.InvokeRequired)
            {
                return (string)this.Invoke(myDelegate);
             }
            else
            {
                return myDelegate();
             }
         }

//别的线程里的调用哇~


string _school = returnCB(returnSchool);


大概就是这样的,貌似有听说最好别用第一种方法,具体为啥我也不知道~反正我一直都用委托的,也不是

很麻烦~

麻烦知道的更清楚的人给说一声为什么,谢谢了~

在多线程编程中,我们经常要在工作线程中去更新界面显示,而在多线程中直接调用界面控件的方法是错误

的做法,Invoke 和 BeginInvoke 就是为了解决这个问题而出现的,使你在多线程中安全的更新界面显示。

正确的做法是将工作线程中涉及更新界面的代码封装为一个方法,通过 Invoke 或者 BeginInvoke 去调用,

两者的区别就是一个导致工作线程等待,而另外一个则不会。

而所谓的“一面响应操作,一面添加节点”永远只能是相对的,使 UI 线程的负担不至于太大而已,因为界

面的正确更新始终要通过 UI 线程去做,我们要做的事情是在工作线程中包揽大部分的运算,而将对纯粹的

界面更新放到 UI 线程中去做,这样也就达到了减轻 UI 线程负担的目的了。

再举个简单例子说明下使用方法,比如你在启动一个线程,在线程的方法中想更新窗体中的一个TextBox..


        using System.Threading;

        public delegate void MyInvoke(string str);
        private void btnStartThread_Click(object sender, EventArgs e)
        {
            Thread thread = new Thread(new ThreadStart(DoWord));
            thread.Start();
        }
        public void DoWord()
        {            
            MyInvoke mi = new MyInvoke(SetTxt);
            BeginInvoke(mi,new object[]{"abc"});               
        }

        public void SetTxt(string str)
        {
            txtReceive.Text += str + System.Environment.NewLine;
        }

看看我的代码托管:

public delegate void MyInvoke(string str);
        public void SetTxt(string str)
        {
            m_receive_text.Text += str;
        }


        public void showMessage()
        {
            MyInvoke mi = new MyInvoke(SetTxt);
            while (true)
            {
                if (serial.m_responses.Count != 0)
                {
                  
                     
                    BeginInvoke(mi, new object[] { serial.m_responses[0] });                     
                    serial.m_responses.RemoveAt(0);                  

                }
                else
                {
                    System.Threading.Thread.Sleep(200); // 等待2个tick
                }
            }
        }

方法1   例子
                //更新ListBox信息
                public   delegate   void   UpdateListBoxCallback();

                //更新用户列表
                private   void   UpdateClientListControl()
                {
                        if   (InvokeRequired)
                        {
                                listBoxClientList.BeginInvoke(new   UpdateListBoxCallback(UpdateClientList),   null);
                        }
                        else
                        {
                                //创建该控件的主线程直接更新信息列表
                                UpdateClientList();
                        }
                }

              //更新代码在这里
                public   void   UpdateClientList()
                {
                        listBoxClientList.Items.Clear();
                        for   (int   index   =   0;   index   <   WorkerSocketList.Count;   index++)
                        {
                                string   clientKey   =   Convert.ToString(index   +   1);
                                Socket   workerSocket   =   (Socket)WorkerSocketList[index];
                                if   (workerSocket   !=   null)
                                {
                                        //将连接着服务器的客户添加到客户列表中
                                        if   (workerSocket.Connected)
                                        {
                                                listBoxClientList.Items.Add(clientKey);
                                        }
                                }
                        }
                }

方法2   例子
                public   delegate   void   ShowMacInList(ListBox   listBox,   object   obj);
                public   event   ShowMacInList   ShowAllRresultInList;
//链接
this.ShowAllRresultInList   +=   new   ShowMacInList(RWOL_ShowAllRresultInList);
//
                void   RWOL_ShowAllRresultInList(ListBox   listBox,   object   obj)
                {
                        try
                        {
                                this.BeginInvoke(new   ShowMacInList(ShowResult),
                                                                new   object[]   {   listBox,   obj   });
                        }
                        catch
                        {
              }

参考:CSDN
回复 使用道具 举报
多线程 是个很深奥的问题,一直不怎么懂,

但是我知道 silverlight 开发中, 因为市场和webservice  和WCF 打交道进行异步数据处理
这时会有很多地方通过多线程,

因为这个时候通过这种非 ADO.NET  方式去获取数据,等,

在数据量非常大的时候,我们就需要开多线程, 单独开一个线程进行数据处理,另外在开一个线程进行UI绘制

大概的思路就是 Thread th = new Thread(methodName);

具体的,楼主可以查阅一下网上的相关资料

评分

参与人数 1技术分 +1 收起 理由
陈涛 + 1

查看全部评分

回复 使用道具 举报
您需要登录后才可以回帖 登录 | 加入黑马