C#多线程 线程的启动

在实例化Thread的实例,需要提供一个委托,在实例化这个委托时所用到的参数是线程将来启动时要运行的方法。在.net中提供了两种启动线程的方式,一种是不带参数的启动方式,另一种是带参数的启动的方式。

不带参数的启动方式

如果启动参数时无需其它额外的信息,可以使用ThreadStart来实例化Thread,如下面的代码:

 1 using System;
 2 using System.Collections.Generic;
 3 using System.Text;
 4 using System.Threading;
 5
 6 namespace ConsoleApplication_Thread
 7 {
 8     class Program
 9     {
10         int interval = 200;
11         static void Main(string[] args)
12         {
13             Program p = new Program();
14             Thread nonParameterThread = new Thread(new ThreadStart(p.NonParameterRun));
15             //Thread nonParameterThread = new Thread(p.NonParameterRun);
16             nonParameterThread.Start();
17         }
18
19         /// <summary>
20         ///  不带参数的启动方法
21         /// </summary>
22         public void NonParameterRun()
23         {
24             for (int i = 0; i < 10; i++)
25             {
26                 Console.WriteLine("系统当前时间毫秒值:"+DateTime.Now.Millisecond.ToString());
27                 Thread.Sleep(interval);
28             }
29             Console.ReadKey();
30         }
31     }
32 }

程序的运行效果我们不用运行也会知道,那就是在循环中将系统当前时间的毫秒部分输出出来,在每次输出之后会将当前线程暂停一下,直到10次之后运行完毕,终止线程的执行。

在上面的代码中我们是通过定义全局变量的方法来指定线程暂停间隔,按照这种方法,假如要运行10个线程,每个线程的暂停间隔不一样的话,就需要定义10个全局变量,虽然最终不影响系统的运行效果,但是总觉得不是太爽。有没有比较简单一点的办法呢?有!那就是使用带参数的启动方法。

带参数的启动方法

如果要在实例化线程时要带一些参数,就不能用ThreadStart委托作为构造函数的参数来实例化Thread了,而要
ParameterizedThreadStart委托,和ThreadStart一样的是它也是线程启动时要执行的方法,和ThreadStart不同的是,它在实例化时可以用一个带有一个Object参数的方法作为构造函数的参数,而实例化ThreadStart时所用到的方法是没有参数的。

为什么是Object这样的参数呢?很简单,因为在.net中Object是所有类型的基类,用它可以表示Array(数组)、Interface(接口)、ValueType(值类型,如bool,byte,char,short,int,float,long,double等)、class(类)等.net中的类型。当然,这也意味着如果你要启动一个线程,给它传递一个int类型参数时,必须在启动方法中进行相应的类型转换。

下面就是一个例子,在启动线程时指定了线程的暂停间隔,代码如下:

 1 using System;
 2 using System.Collections.Generic;
 3 using System.Text;
 4 using System.Threading;
 5
 6 namespace ConsoleApplication_Thread
 7 {
 8     class Program
 9     {
10         //int interval = 200;
11         static void Main(string[] args)
12         {
13             Program p = new Program();
14             Thread parameterThread = new Thread(new ParameterizedThreadStart(p.ParameterRun));
15             parameterThread.Name = "线程1:";//指定当前线程名称
16             parameterThread.Start(1000);//将值1000传递给子线程委托方法的参数上
17         }
18
19         /// <summary>
20         /// 带参数的启动方法
21         /// </summary>
22         /// <param name="ms"></param>
23         public void ParameterRun(object ms)
24         {
25             int j = 10;
26             int.TryParse(ms.ToString(), out j);//这里采用了TryParse方法,避免不能转换时出现异常
27
28             for (int i = 0; i < 10; i++)
29             {
30                 Console.WriteLine(Thread.CurrentThread.Name + "系统当前时间毫秒值:" + DateTime.Now.Millisecond.ToString());
31                 Thread.Sleep(j);
32             }
33             Console.ReadLine();
34         }
35     }
36 }

在这个方法里,我们在启动线程时顺便指定了线程的暂停间隔,也就是这句:
parameterThread.Start(30);
线程启动时运行的方法是public
void ParameterRun(object
ms),这个值为1000的int类型变量被装箱成object,所以在方法中还需要将它转换成int类型,这个可以通过拆箱或者其它办法解决。

假如我们要启动两个线程,每个线程的暂停间隔不一样,启动代码如下:

 1 using System;
 2 using System.Collections.Generic;
 3 using System.Text;
 4 using System.Threading;
 5
 6 namespace ConsoleApplication_Thread
 7 {
 8     class Program
 9     {
10         //int interval = 200;
11         static void Main(string[] args)
12         {
13             Program p = new Program();
14             Thread parameterThread = new Thread(new ParameterizedThreadStart(p.ParameterRun));
15             parameterThread.Name = "Thread A:";
16             parameterThread.Start(3000);
17             //启动第二个线程
18             parameterThread = new Thread(new ParameterizedThreadStart(p.ParameterRun));
19             parameterThread.Name = "Thread B:";
20             parameterThread.Start(6000);
21         }
22
23         /// <summary>
24         /// 带参数的启动方法
25         /// </summary>
26         /// <param name="ms">让线程在运行过程中的休眠间隔</param>
27         public void ParameterRun(object ms)
28         {
29             int j = 10;
30             int.TryParse(ms.ToString(), out j);//这里采用了TryParse方法,避免不能转换时出现异常
31             for (int i = 0; i < 10; i++)
32             {
33                 Console.WriteLine(Thread.CurrentThread.Name + "系统当前时间毫秒值:" + DateTime.Now.Millisecond.ToString());
34                 Thread.Sleep(j);//让线程暂停
35             }
36             Console.ReadKey();
37         }
38     }
39 }

对上面的代码做一点说明,就是线程启动之后,线程的实例不必再存在(也就是说实例被销毁了),例如在上面的代码中我用的是同一个实例实例化了两个线程,并且这两个线程运行很正常。

继续探索

上面解决了一个问题,如果在启动线程时需要参数如何解决,如果针对上面的问题继续发掘,比如:在启动线程时不但要指定线程的暂停间隔,还需要指定循环次数(在上面的所有例子中都是执行10次的),说白点就是我需要很多的参数,这个问题该如何解决呢?

有两种办法可以解决:

首先可以继续在ParameterizedThreadStart这里做文章,因为这里可以使用一个Object类型的参数,那么可以通过数组或者一个类来解决(因为它们都是Object的子类)。我在做某个系统时确实采用数组处理过这种情况,这样就要求在线程启动方法中必须清楚知道数组中每个参数的用途,不是太方便。
这里说说重新定义一个实体类来解决的方法,代码如下:

 1 using System;
 2 using System.Collections.Generic;
 3 using System.Text;
 4 using System.Threading;
 5
 6 namespace ConsoleApplication_Thread
 7 {
 8     class Program
 9     {
10         //int interval = 200;
11         static void Main(string[] args)
12         {
13             Program p = new Program();
14             Thread parameterThread = new Thread(new ParameterizedThreadStart(p.MyParameterRun));
15             parameterThread.Name = "线程 A:";
16             MyThreadParameter paramter = new MyThreadParameter(1000, 20);
17             parameterThread.Start(paramter);
18         }
19
20
21         /// <summary>
22         /// 带多个参数的启动方法
23         /// </summary>
24         /// <param name="ms">方法参数</param>
25         public void MyParameterRun(object ms)
26         {
27             MyThreadParameter parameter = ms as MyThreadParameter;//类型转换
28             if (parameter != null)
29             {
30                 for (int i = 0; i < parameter.LoopCount; i++)
31                 {
32                     Console.WriteLine(Thread.CurrentThread.Name + "系统当前时间毫秒值:" + DateTime.Now.Millisecond.ToString());
33                     Thread.Sleep(parameter.Interval);//让线程暂停
34                 }
35                 Console.ReadKey();
36             }
37         }
38
39
40     }
41     class MyThreadParameter
42     {
43         private int interval;
44         private int loopCount;
45         /// <summary>
46         /// 循环次数
47         /// </summary>
48         public int LoopCount
49         {
50             get { return loopCount; }
51         }
52
53         /// <summary>
54         /// 线程的暂停间隔
55         /// </summary>
56         public int Interval
57         {
58             get { return interval; }
59         }
60         /// <summary>
61         /// 构造函数
62         /// </summary>
63         /// <param name="interval">线程的暂停间隔</param>
64         /// <param name="loopCount">循环次数</param>
65         public MyThreadParameter(int interval, int loopCount)
66         {
67             this.interval = interval;
68             this.loopCount = loopCount;
69         }
70     }
71 }

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

 1 using System;
 2 using System.Collections.Generic;
 3 using System.Text;
 4 using System.Threading;
 5
 6 namespace ConsoleApplication_Thread
 7 {
 8     class Program
 9     {
10         static void Main(string[] args)
11         {
12             MyThreadParameter parameterThread = new myThreadParameter(200, 50);
13             parameterThread.Start();
14         }
15     }
16
17
18     class MyThreadParameter
19     {
20
21         private int interval;
22         private int loopCount;
23         private Thread thread;
24         /// <summary>
25         /// 构造函数
26         /// </summary>
27         /// <param name="interval">线程的暂停间隔</param>
28         /// <param name="loopCount">循环次数</param>
29         public MyThreadParameter(int interval, int loopCount)
30         {
31             this.interval = interval;
32             this.loopCount = loopCount;
33             thread = new Thread(new ThreadStart(Run));
34         }
35         public void Start()
36         {
37             if (thread != null)
38             {
39                 thread.Start();
40             }
41         }
42         private void Run()
43         {
44             for (int i = 0; i < loopCount; i++)
45             {
46                 Console.WriteLine("系统当前时间毫秒值:" + DateTime.Now.Millisecond.ToString());
47                 Thread.Sleep(interval);//让线程暂停
48             }
49         }
50     }
51 }

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

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

时间: 2024-11-09 00:41:02

C#多线程 线程的启动的相关文章

Java语言基础-多线程-①线程的创建和启动

简单阐释进程和线程 对于进程最直观的感受应该就是“windows任务管理器”中的进程管理: (计算机原理课上的记忆已经快要模糊了,简单理解一下):一个进程就是一个“执行中的程序”,是程序在计算机上的一次运行活动.程序要运行,系统就在内存中为该程序分配一块独立的内存空间,载入程序代码和资源进行执行.程序运行期间该内存空间不能被其他进程直接访问.系统以进程为基本单位进行系统资源的调度和分配.何为线程?线程是进程内一次具体的执行任务.程序的执行具体是通过线程来完成的,所以一个进程中至少有一个线程.回忆

多线程基础二(线程的启动、终止,线程面临的三种问题)

一.线程的启动.终止方式 启动: start native(调用外部接口启动) 终止:    stop(类似kill,暴力终止)  interrupt 中断的方式 通过指令的方式 volatile boolean stop = false; public class InterruptDemo { private static int i; public static void main(String[] args) { Thread thread = new Thread(()->{ whil

多线程——线程的运行状态(面试题)

线程的启动使用的是start()方法,但是并不是意味着调用了start方法就立刻启动多线程. 线程转换状态: 当多线程调用了start()方法之后并不是立刻执行,而是进入了就绪状态,等待进行调度后执行.调度就是需要将资源分配给程序运行后才可以执行多线程中的代码(run中的代码).但这个程序并不是一直执行的,在执行了一段时间之后,需要让出资源,让其它线程来继续执行.即run方法可能还没执行完,可能只执行了一半,那么这个时候让出资源,随后要重新进入就绪状态,重新等待分配新资源,再继续执行.当线程执行

C#多线程--线程池(ThreadPool)

先引入一下线程池的概念: 百度百科:线程池是一种多线程处理形式,处理过程中将任务添加到队列,然后在创建线程后自动启动这些任务.线程池线程都是后台线程.每个线程都使用默认的堆栈大小,以默认的优先级运行,并处于多线程单元中.如果某个线程在托管代码中空闲(如正在等待某个事件),则线程池将插入另一个辅助线程来使所有处理器保持繁忙.如果所有线程池线程都始终保持繁忙,但队列中包含挂起的工作,则线程池将在一段时间后创建另一个辅助线程但线程的数目永远不会超过最大值.超过最大值的线程可以排队,但他们要等到其他线程

多线程-线程间通信

1.多线程-线程间通信-问题演示 多线程间通信:多个线程处理同一资源,但是处理动作却不同. //创建一个资源描述.资源中有name sex.用于存储数据. class Resource{     String name;     String sex; } //需要定义一个输入任务描述.既然是线程任务,必须实现Runnable接口.  class Input implements Runnable{     private Resource r;     Input(Resource r){  

Java的多线程 --线程的状态

线程可以有6中状态. [1].New(新生) [2].Runnable(可运行) [3].Blocked(被阻塞) [4].Waiting(等待) [5].Timed Waiting(计时等待) [6].Terminated(被终止) 1.新生(New)线程: 当使用new 操作符创建一个先的线程,但该线程还没有调用start()方法.线程这个时候的状态就是新生,这个时候我们可以做些初始化之类的工作. 2.可运行(Runnable)线程: 一旦调用了start()方法,这个线程就处于可运行(Ru

Java的多线程 --线程的概念

Java的多线程--线程的概念 一个程序同时执行多个任务,通常,每个任务称之为线程(thread),她是线程控制的简称. 可以运行一个以上的任务的程序叫做多线程程序. 1.感觉线程和进程很像,那么他们的区别是什么? 其实他们是有本质的区别:每个进程拥有自己独立的一整套变量,而线程则共享数据. 2.在Java中怎么创建一个线程去执行一个任务. 主要有4个步骤. 1)将任务代码移到实现了Runnable接口类的run方法中,这个接口很简单,只有一个方法. public interface Runna

java 多线程—— 线程让步

java 多线程 目录: Java 多线程——基础知识 Java 多线程 —— synchronized关键字 java 多线程——一个定时调度的例子 java 多线程——quartz 定时调度的例子 java 多线程—— 线程等待与唤醒 java 多线程—— 线程让步 概述 第1 部分 yield()介绍 第2 部分 yield()示例 第3 部分 yield() 与 wait()的比较 第1 部分 yield()介绍 yield()的作用是让步.它能让当前线程由“运行状态”进入到“就绪状态”

线程的启动(转)

目录 C#多线程编程(1):线程的启动 1.不带参数的启动方式 2.带参数的启动方法 3.以类的实例作为参数 4.把Thread要处理的业务代码放在一个单独的类中 C#多线程编程(1):线程的启动 在实例化Thread的实例,需要提供一个委托,在实例化这个委托时所用到的参数是线程将来启动时要运行的方法. 在.net中提供了两种启动线程的方式,一种是不带参数的启动方式,另一种是带参数的启动的方式. 1.不带参数的启动方式 如果启动参数时无需其它额外的信息,可以使用ThreadStart来实例化Th