赞助商
上一篇:浅谈.NET下的多线程和并行计算(一)前言

首先来看看如何创建线程:
  1. Console.WriteLine(Process.GetCurrentProcess().Threads.Count);
  2. Thread t1 = new Thread(() =>
  3.     {
  4.         Thread.Sleep(1000);
  5.         Thread t = Thread.CurrentThread;
  6.         Console.WriteLine("Name: " + t.Name);
  7.         Console.WriteLine("ManagedThreadId: " + t.ManagedThreadId);
  8.         Console.WriteLine("State: " + t.ThreadState);
  9.         Console.WriteLine("Priority: " + t.Priority);
  10.         Console.WriteLine("IsBackground: " + t.IsBackground);
  11.         Console.WriteLine("IsThreadPoolThread: " + t.IsThreadPoolThread);
  12.     })
  13.     {
  14.         Name = "Thread1",
  15.         Priority = ThreadPriority.Highest
  16.     };
  17. t1.Start();
  18. Console.WriteLine(Process.GetCurrentProcess().Threads.Count);
复制代码
我们在Thread的构造方法中传入一个Lambda表达式,对应ThreadStart委托(无参void返回值的方法)来构造一个线程任务。这段程序中有几个注意点:

1)从输出结果中可以看到,当前程序启动后就3三个线程,新开线程后显示为4个线程,在线程方法中休眠了一秒,防止主线程执行完次线程就过早结束了。

2)我们可以为线程设置一个名字,方便调试。我们也可以设置线程的优先级,这个在之后会有进一步介绍。

3)第7行,托管线程的唯一标识符,微软建议使用托管线程的Id而不是操作系统中线程的Id来跟踪线程。

4)第10行代码输出了当前线程不是后台线程,也就是是前台线程,这是默认值。进程会等待前台线程结束结束,而如果是后台线程的话,所有前台线程结束后后台线程自动终止。对于Windows GUI应用程序来说,使用后台线程很可能发生诡异现象,也就是在程序从任务管理器的应用程序一栏中消失后其进程还在,只能通过手动终止进程来释放内存。

5)第11行代码表明这个线程不是由线程池创建的,有关线程池见后文的介绍。

附件: image_2.png

那么我们再来看看如何为线程传入参数,一种方式是使用匹配ParameterizedThreadStart委托(object参数void返回值)的方法:
  1. new Thread((date) => Console.WriteLine(((DateTime)date).ToString())).Start(DateTime.Now);
复制代码
由于参数是object类型的,我们在使用的时候不得不进行转换,而且还有一个问题就是不支持多个参数,如果要多个参数的话只能使用自定义的对象进行包装,我们还可以使用另外一种方法,那就是使用一个无参方法来包装线程方法主体:
  1. new Thread(() => Add(1, 2)).Start();

  2. static void Add(int i, int j)
  3. {
  4.     Console.WriteLine(i + j);
  5. }
复制代码
上述几行代码的运行结果如下:

附件: image_4.png

再来看一下后台线程前台线程:
  1. new Thread(() => Console.ReadLine()) { IsBackground = false }.Start();
复制代码
这是默认情况,可以看到控制台一直在等待用户的输入,按回车后程序结束,如果把IsBackground属性设置为true的话,可以看到程序在运行后马上接结束了,并没有等待线程方法的结束。

之前说过线程的优先级属性,我们做一个实验:
  1. bool b = true;
  2. new Thread(() =>
  3. {
  4.     while (b)
  5.     {
  6.         i++;
  7.     }
  8. }) { Priority = ThreadPriority.Highest }.Start();

  9. new Thread(() =>
  10. {
  11.     while (b)
  12.     {
  13.         j++;
  14.     }
  15. }) { Priority = ThreadPriority.Lowest }.Start();

  16. Thread.Sleep(1000);
  17. b = false;
  18. Console.WriteLine("i: {0}, j: {1}", i, j);
复制代码
开启两个线程做的事情很简单,累加一个静态变量的值,一个优先级最高,一个优先级最低,然后让主线程等待1秒输出结果:

附件: image_6.png

从结果中可以看到,优先级高的线程得到运行的次数比优先级低的线程多那么一点,但即使是最低优先级的线程都有很大的机会来执行。
赞助商
赞助商
TOP