当前位置:  编程技术>.net/c#/asp.net

C#线程定义和使用方法详解

    来源: 互联网  发布时间:2014-10-24

    本文导语:  一、C# Thread类的基本用法 通过System.Threading.Thread类可以开始新的线程,并在线程堆栈中运行静态或实例方法。可以通过Thread类的的构造方法传递一个无参数,并且不返回值(返回void)的委托(ThreadStart),这个委托的定义如下: [...

一、C# Thread类的基本用法

通过System.Threading.Thread类可以开始新的线程,并在线程堆栈中运行静态或实例方法。可以通过Thread类的的构造方法传递一个无参数,并且不返回值(返回void)的委托(ThreadStart),这个委托的定义如下:

[ComVisibleAttribute(true)]

public delegate void ThreadStart()

我们可以通过如下的方法来建立并运行一个线程。

代码如下:

using System; 
using System.Collections.Generic; 
using System.Linq; 
using System.Text; 
using System.Threading; 

namespace MyThread 

class Program 

public static void myStaticThreadMethod() 

Console.WriteLine("myStaticThreadMethod"); 

static void Main(string[] args) 

Thread thread1 = new Thread(myStaticThreadMethod); 
thread1.Start();  // 只要使用Start方法,线程才会运行 


}

除了运行静态的方法,还可以在线程中运行实例方法,代码如下:

代码如下:

 using System; 
using System.Collections.Generic; 
using System.Linq; 
using System.Text; 
using System.Threading; 

namespace MyThread 

class Program 

public void myThreadMethod() 

Console.WriteLine("myThreadMethod"); 

static void Main(string[] args) 

Thread thread2 = new Thread(new Program().myThreadMethod); 
thread2.Start(); 


}

如果读者的方法很简单,或出去某种目的,也可以通过匿名委托或Lambda表达式来为Thread的构造方法赋值,代码如下:

代码如下:

Thread thread3 = new Thread(delegate() { Console.WriteLine("匿名委托"); }); 
thread3.Start(); 
Thread thread4 = new Thread(( ) => { Console.WriteLine("Lambda表达式"); }); 
thread4.Start(); 

其中Lambda表达式前面的( )表示没有参数。

为了区分不同的线程,还可以为Thread类的Name属性赋值,代码如下:

代码如下:

Thread thread5 = new Thread(()=>{ Console.WriteLine(Thread.CurrentThread.Name); }); 
thread5.Name = "我的Lamdba"; 
thread5.Start();

如果将上面thread1至thread5放到一起执行,由于系统对线程的调度不同,输出的结果是不定的,如图1是一种可能的输出结果。

二、 定义一个线程类

我们可以将Thread类封装在一个MyThread类中,以使任何从MyThread继承的类都具有多线程能力。MyThread类的代码如下:

代码如下:

using System; 
using System.Collections.Generic; 
using System.Linq; 
using System.Text; 
using System.Threading; 
namespace MyThread 

   abstract class MyThread 

   Thread thread = null; 

   abstract public void run(); 

public void start() 

if (thread == null) 
thread = new Thread(run); 
thread.Start(); 


}

可以用下面的代码来使用MyThread类。

代码如下:

class NewThread : MyThread 

  override public void run() 
  { 
  Console.WriteLine("使用MyThread建立并运行线程"); 
  } 
  } 

  static void Main(string[] args) 
  { 

  NewThread nt = new NewThread(); 
  nt.start(); 
  }

我们还可以利用MyThread来为线程传递任意复杂的参数。详细内容见下节。

三、C# Thread类:为线程传递参数

Thread类有一个带参数的委托类型的重载形式。这个委托的定义如下:

[ComVisibleAttribute(false)]

public delegate void ParameterizedThreadStart(Object obj)

 

这个Thread类的构造方法的定义如下:

public Thread(ParameterizedThreadStart start);
下面的代码使用了这个带参数的委托向线程传递一个字符串参数:

代码如下:

public static void myStaticParamThreadMethod(Object obj) 

Console.WriteLine(obj); 


static void Main(string[] args) 

  Thread thread = new Thread(myStaticParamThreadMethod); 
  thread.Start("通过委托的参数传值"); 
}

要注意的是,如果使用的是不带参数的委托,不能使用带参数的Start方法运行线程,否则系统会抛出异常。但使用带参数的委托,可以使用thread.Start()来运行线程,这时所传递的参数值为null。

也可以定义一个类来传递参数值,如下面的代码如下:

代码如下:

class MyData 

private String d1; 
private int d2; 
public MyData(String d1, int d2) 

  this.d1 = d1; 
  this.d2 = d2; 

public void threadMethod() 

  Console.WriteLine(d1); 
  Console.WriteLine(d2); 



MyData myData = new MyData("abcd",1234); 
Thread thread = new Thread(myData.threadMethod); 
thread.Start();

如果使用在第二节定义的MyThread类,传递参数会显示更简单,代码如下:

代码如下:

class NewThread : MyThread 

private String p1; 
private int p2; 
public NewThread(String p1, int p2) 

this.p1 = p1; 
this.p2 = p2; 


override public void run() 

Console.WriteLine(p1); 
Console.WriteLine(p2); 



NewThread newThread = new NewThread("hello world", 4321); 
newThread.start();

四、前台和后台线程

使用Thread建立的线程默认情况下是前台线程,在进程中,只要有一个前台线程未退出,进程就不会终止。主线程就是一个前台线程。而后台线程不管线程是否结束,只要所有的前台线程都退出(包括正常退出和异常退出)后,进程就会自动终止。一般后台线程用于处理时间较短的任务,如在一个Web服务器中可以利用后台线程来处理客户端发过来的请求信息。而前台线程一般用于处理需要长时间等待的任务,如在Web服务器中的监听客户端请求的程序,或是定时对某些系统资源进行扫描的程序。下面的代码演示了前台和后台线程的区别


代码如下:

public static void myStaticThreadMethod() 

Thread.Sleep(3000); 


Thread thread = new Thread(myStaticThreadMethod); 
// thread.IsBackground = true; 
thread.Start();

如果运行上面的代码,程序会等待3秒后退出,如果将注释去掉,将thread设成后台线程,则程序会立即退出。

要注意的是,必须在调用Start方法之前设置线程的类型,否则一但线程运行,将无法改变其类型。

通过BeginXXX方法运行的线程都是后台线程。

五、C# Thread类:判断多个线程是否都结束的两种方法

确定所有线程是否都完成了工作的方法有很多,如可以采用类似于对象计数器的方法,所谓对象计数器,就是一个对象被引用一次,这个计数器就加1,销毁引用就减1,如果引用数为0,则垃圾搜集器就会对这些引用数为0的对象进行回收。

方法一:线程计数器

线程也可以采用计数器的方法,即为所有需要监视的线程设一个线程计数器,每开始一个线程,在线程的执行方法中为这个计数器加1,如果某个线程结束(在线程执行方法的最后为这个计数器减1),为这个计数器减1。然后再开始一个线程,按着一定的时间间隔来监视这个计数器,如是棕个计数器为0,说明所有的线程都结束了。当然,也可以不用这个监视线程,而在每一个工作线程的最后(在为计数器减1的代码的后面)来监视这个计数器,也就是说,每一个工作线程在退出之前,还要负责检测这个计数器。使用这种方法不要忘了同步这个计数器变量啊,否则会产生意想不到的后果。

方法二:使用Thread.join方法

join方法只有在线程结束时才继续执行下面的语句。可以对每一个线程调用它的join方法,但要注意,这个调用要在另一个线程里,而不要在主线程,否则程序会被阻塞的。

个人感觉这种方法比较好。

线程计数器方法演示:

代码如下:

class ThreadCounter : MyThread 

private static int count = 0; 
private int ms; 
private static void increment() 

lock (typeof(ThreadCounter))  // 必须同步计数器 

count++; 


private static void decrease() 

lock (typeof(ThreadCounter)) 

count--; 


private static int getCount() 

lock (typeof(ThreadCounter)) 

return count; 


public ThreadCounter(int ms) 

this.ms = ms; 

override public void run() 

increment(); 
Thread.Sleep(ms); 
Console.WriteLine(ms.ToString()+"毫秒任务结束"); 
decrease(); 
if (getCount() == 0) 
Console.WriteLine("所有任务结束"); 



 
ThreadCounter counter1 = new ThreadCounter(3000); 
ThreadCounter counter2 = new ThreadCounter(5000); 
ThreadCounter counter3 = new ThreadCounter(7000); 

counter1.start(); 
counter2.start(); 
counter3.start();

上面的代码虽然在大多数的时候可以正常工作,但却存在一个隐患,就是如果某个线程,假设是counter1,在运行后,由于某些原因,其他的线程并未运行,在这种情况下,在counter1运行完后,仍然可以显示出“所有任务结束”的提示信息,但是counter2和counter3还并未运行。为了消除这个隐患,可以将increment方法从run中移除,将其放到ThreadCounter的构造方法中,在这时,increment方法中的lock也可以去掉了。代码如:

代码如下:

public ThreadCounter(int ms) 
 { 
 this.ms = ms; 
 increment(); 
 }

运行上面的程序后,将显示如图2的结果。

使用Thread.join方法演示

代码如下:

private static void threadMethod(Object obj) 

Thread.Sleep(Int32.Parse(obj.ToString())); 
Console.WriteLine(obj + "毫秒任务结束"); 

private static void joinAllThread(object obj) 

Thread[] threads = obj as Thread[]; 
foreach (Thread t in threads) 
t.Join(); 
Console.WriteLine("所有的线程结束"); 


static void Main(string[] args) 

Thread thread1 = new Thread(threadMethod); 
Thread thread2 = new Thread(threadMethod); 
Thread thread3 = new Thread(threadMethod); 

 thread1.Start(3000); 
 thread2.Start(5000); 
 thread3.Start(7000); 

 Thread joinThread = new Thread(joinAllThread); 
 joinThread.Start(new Thread[] { thread1, thread2, thread3 }); 

}

在运行上面的代码后,将会得到和图2同样的运行结果。上述两种方法都没有线程数的限制,当然,仍然会受到操作系统和硬件资源的限制。


    
 
 

您可能感兴趣的文章:

  • c#多线程更新窗口(winform)GUI的数据
  • c# winform 关闭窗体时同时结束线程实现思路
  • c#多线程读取注册表 c#多线程的小例子
  • C#实现终止正在执行的线程
  • c#后台线程访问前台控件并显示信息示例
  • C#线程间不能调用剪切板的解决方法
  • C#实现线程池的简单示例
  • c# 多线程操作progressBar进度条控件的例子
  • C#子线程更新UI控件的方法实例总结
  • C#实现窗体与子线程的交互的方法
  • C#通过接口与线程通信(捕获线程状态)示例代码
  • C#利用子线程刷新主线程分享教程
  • 描述C#多线程中lock关键字的使用分析
  • C#中的多线程多参数传递详解
  • C# 多线程更新进度条progressBar控件的代码一例
  • C# 多线程复制文件并显示进度条的代码
  • c#(asp.net)线程配置总结
  • c#线程同步的问题与实例分析
  • c#多线程中Lock()关键字的用法小结
  • c#钩子本线程内消息拦截的方法
  • c#线程间传递参数详解
  • java线程之使用Runnable接口创建线程的方法
  • 在线程中使用list的pop_front方法出现异常
  • java线程之join方法的使用介绍
  • java多线程编程之join方法的使用示例
  • C#线程 BeginInvoke和EndInvoke使用方法
  • .NET中保证线程安全的高级方法Interlocked类使用介绍
  • java多线程编程之使用Synchronized块同步方法
  • java多线程编程之使用Synchronized关键字同步类方法
  •  
    本站(WWW.)旨在分享和传播互联网科技相关的资讯和技术,将尽最大努力为读者提供更好的信息聚合和浏览方式。
    本站(WWW.)站内文章除注明原创外,均为转载、整理或搜集自网络。欢迎任何形式的转载,转载请注明出处。












  • 相关文章推荐
  • Java中多线程相关类Thread介绍
  • 一个进程创建了两个线程,如何使得当任何一个线程(比如线程a)结束时,同时也结束线程b,也就是使两个线程一起死掉,怎么办呢?
  • Windows和Linux下C++类成员方法作为线程函数方法介绍
  • java 线程,对当前线程(非主线程)调用sleep,为什么主线程(窗口)也没反应了
  • c++的boost库多线程(Thread)编程(线程操作,互斥体mutex,条件变量)详解
  • 如何实现一个线程组内多线程的非同不执行,即一个线程执行完毕后再执行下一个线程???
  • Linux下GCC内置原子操作函数(多线程资源访问)介绍
  • 请问:进程创建的线程是怎样运行的啊,线程的处理函数运行完了,线程就退出了吗?
  • 关于线程的问题,什么样的线程不是active线程?
  • 请问Linux核心支持多线程吗?开发库有线程库吗?线程好用吗?(稳定?)
  • 请问,在一个进程中创建多线程时如何能避免不同的线程获得同一个线程标识
  • 我的一个多线程服务里, 总是有一个线程莫名其妙的变成僵尸线程。
  • 能否通过线程id控制线程的状态?或是观察到线程的状态?
  • 如何在一个线程中启动另外一个线程,然后本线程就退出?
  • 我要设置一个线程的优先级, 这个属性结构并没有线程的id,它怎么知道是设置哪个线程呢?
  • 请问在java多线程中,是只有run(){}内的代码运行在一个新线程下呢?还是这个类中的代码都运行在一个新线程下?
  • gcc链接的库,分不分单线程版本的和多线程版本的?
  • 内核栈~ 内核线程 ~用户线程 之间关系 问题
  • 子线程的数据如何返回给主线程?
  • 如果父线程死掉 那么子线程会不会死掉呢
  • 多线程为何比单线程慢许多?


  • 站内导航:


    特别声明:169IT网站部分信息来自互联网,如果侵犯您的权利,请及时告知,本站将立即删除!

    ©2012-2021,,E-mail:www_#163.com(请将#改为@)

    浙ICP备11055608号-3