百度空间 | 百度首页 
 
查看文章
 
[转]C#多线程编程(2):线程的启动
2009年08月04日 星期二 11:24

继续探索
上面解决了一个问题,如果在启动线程时需要参数如何解决,如果针对上面的问题继续发掘,比如:在启动线程时不但要指定线程的暂停间隔,还需要指定循环次数(在上面的所有例子中都是执行10次的),这个问题该如何解决呢?
有两种办法可以解决:
首先可以继续在ParameterizedThreadStart这里做文章,因为这里可以使用一个Object类型的参数,那么可以通过数组或者一个类来解决(因为它们都是Object的子类)。我在做某个系统时确实采用数组处理过这种情况,这样就要求在线程启动方法中必须清楚知道数组中每个参数的用途,不是太方便。
这里说说重新定义一个实体类来解决的方法,代码如下。

view plaincopy to clipboardprint?
using System;  
    using System.Collections.Generic;  
    using System.Text;  
    using System.Threading;  
      
    namespace StartThread  
    {  
        class MyThreadParameter  
        {  
            private int interval;  
            private int loopCount;  
            /// <summary>  
            /// 循环次数  
            /// </summary>  
            public int LoopCount  
            {  
                get { return loopCount; }  
            }  
          
            /// <summary>  
            /// 线程的暂停间隔  
            /// </summary>  
            public int Interval  
            {  
                get { return interval; }  
            }  
            /// <summary>  
            /// 构造函数  
            /// </summary>  
            /// <param name="interval">线程的暂停间隔</param>  
            /// <param name="loopCount">循环次数</param>  
            public MyThreadParameter(int interval,int loopCount)  
            {  
                this.interval = interval;  
                this.loopCount = loopCount;  
            }  
        }  
        class Program  
        {  
            int interval = 200;  
            static void Main(string[] args)  
            {  
                Program p = new Program();  
      
                Thread parameterThread = new Thread(new ParameterizedThreadStart(p.MyParameterRun));  
                parameterThread.Name = "Thread A:";  
                MyThreadParameter paramter = new MyThreadParameter(50, 20);  
                parameterThread.Start(paramter);  
            }  
       
      
            /// <summary>  
            /// 带多个参数的启动方法  
            /// </summary>  
            /// <param name="ms">方法参数</param>  
            public void MyParameterRun(object ms)  
            {  
                MyThreadParameter parameter = ms as MyThreadParameter;//类型转换  
                if (parameter != null)  
                {  
                    for (int i = 0; i < parameter.LoopCount; i++)  
                    {  
                        Console.WriteLine(Thread.CurrentThread.Name + "系统当前时间毫秒值:" + DateTime.Now.Millisecond.ToString());  
                        Thread.Sleep(parameter.Interval);//让线程暂停  
                    }  
                }  
            }  
        }  
    }
using System;
using System.Collections.Generic;
using System.Text;
using System.Threading;

namespace StartThread
{
     class MyThreadParameter
     {
         private int interval;
         private int loopCount;
         /// <summary>
         /// 循环次数
         /// </summary>
         public int LoopCount
         {
             get { return loopCount; }
         }

         /// <summary>
         /// 线程的暂停间隔
         /// </summary>
         public int Interval
         {
             get { return interval; }
         }
      /// <summary>
      /// 构造函数
      /// </summary>
         /// <param name="interval">线程的暂停间隔</param>
         /// <param name="loopCount">循环次数</param>
         public MyThreadParameter(int interval,int loopCount)
         {
             this.interval = interval;
             this.loopCount = loopCount;
         }
     }
     class Program
     {
         int interval = 200;
         static void Main(string[] args)
         {
             Program p = new Program();

             Thread parameterThread = new Thread(new ParameterizedThreadStart(p.MyParameterRun));
             parameterThread.Name = "Thread A:";
             MyThreadParameter paramter = new MyThreadParameter(50, 20);
             parameterThread.Start(paramter);
         }


         /// <summary>
         /// 带多个参数的启动方法
         /// </summary>
         /// <param name="ms">方法参数</param>
         public void MyParameterRun(object ms)
         {
             MyThreadParameter parameter = ms as MyThreadParameter;//类型转换
             if (parameter != null)
             {
                 for (int i = 0; i < parameter.LoopCount; i++)
                 {
                     Console.WriteLine(Thread.CurrentThread.Name + "系统当前时间毫秒值:" + DateTime.Now.Millisecond.ToString());
                     Thread.Sleep(parameter.Interval);//让线程暂停
                 }
             }
         }
     }
}

第二种方法和上面方法有些相似,也是需要引入外部类,并且将Thread实例放在引入的类中,这种情况适合于在线程中处理的业务逻辑比较复杂的情况。在前不久处理的一个项目中我用过这种情况,它是用来实现双向数据传输的。
如果实现上面的效果,代码如下:

view plaincopy to clipboardprint?
using System;  
    using System.Collections.Generic;  
    using System.Text;  
    using System.Threading;  
      
    namespace StartThread  
    {  
        class MyThreadParameter  
        {  
            private int interval;  
            private int loopCount;  
            private Thread thread;  
              
        /// <summary>  
        /// 构造函数  
        /// </summary>  
            /// <param name="interval">线程的暂停间隔</param>  
            /// <param name="loopCount">循环次数</param>  
            public MyThreadParameter(int interval,int loopCount)  
            {  
                this.interval = interval;  
                this.loopCount = loopCount;  
                thread = new Thread(new ThreadStart(Run));  
            }  
      
            public void Start()  
            {  
                if (thread != null)  
                {  
                    thread.Start();  
                }  
            }  
      
            private void Run()  
            {  
                for (int i = 0; i < loopCount; i++)  
                {  
                    Console.WriteLine("系统当前时间毫秒值:" + DateTime.Now.Millisecond.ToString());  
                    Thread.Sleep(interval);//让线程暂停  
                }  
            }  
        }  
        class Program  
        {  
            static void Main(string[] args)  
            {  
                MyThreadParameter parameterThread = new MyThreadParameter(30, 50);  
                parameterThread.Start();  
            }  
      
        }  
    }
using System;
using System.Collections.Generic;
using System.Text;
using System.Threading;

namespace StartThread
{
     class MyThreadParameter
     {
         private int interval;
         private int loopCount;
         private Thread thread;
        
/// <summary>
/// 构造函数
/// </summary>
         /// <param name="interval">线程的暂停间隔</param>
         /// <param name="loopCount">循环次数</param>
         public MyThreadParameter(int interval,int loopCount)
         {
             this.interval = interval;
             this.loopCount = loopCount;
             thread = new Thread(new ThreadStart(Run));
         }

         public void Start()
         {
             if (thread != null)
             {
                 thread.Start();
             }
         }

         private void Run()
         {
             for (int i = 0; i < loopCount; i++)
             {
                 Console.WriteLine("系统当前时间毫秒值:" + DateTime.Now.Millisecond.ToString());
                 Thread.Sleep(interval);//让线程暂停
             }
         }
     }
     class Program
     {
         static void Main(string[] args)
         {
             MyThreadParameter parameterThread = new MyThreadParameter(30, 50);
             parameterThread.Start();
         }

     }
}

上面的代码的运行效果和前面的代码运行效果类似,只不过是将业务处理代码放在一个单独的类MyThreadParameter中,使得MyThreadParameter看起来也像一个Thread,实际上维护的还是其内部的Thread,在一些大型系统中这样做的好处是便于维护。

总结:在本篇主要讲述如何启动线程的问题,在启动时可能会遇到无需参数、需要多个参数的情况,在这里讲述了如何解决这些问题的思路。在.net类库中虽然存在着庞大的类库,但是并不是总会有合适的类来解决我们所遇到的问题,但是只要肯动脑筋总会想到合适的办法。


本文来自CSDN博客,出处:http://blog.csdn.net/zhoufoxcn/archive/2009/08/03/4402999.aspx


类别:Csharp | 添加到搜藏 | 浏览() | 评论 (0)
 
最近读者:
 
网友评论:
发表评论:
姓 名:
网址或邮箱: (选填)
内 容:
验证码: 请点击后输入四位验证码,字母不区分大小写
      

     

©2009 Baidu