快速业务通道

浅谈.NET下的多线程和并行计算(二)线程基本知识

作者 佚名技术 来源 NET编程 浏览 发布时间 2012-05-20
优先级最低,然后让 主线程等待1秒输出结果:

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

现在再来看看线程的中断:

Thread t2 = new Thread(() =>
   {
     try
     {
       while (true)
       {
         Console.WriteLine(Thread.CurrentThread.ThreadState);
         Thread.Sleep(1000);
       }
     }
     catch (ThreadAbortException abortException)
     {
       Console.WriteLine("catch");
       Console.WriteLine(Thread.CurrentThread.ThreadState);
       Console.WriteLine((string)abortException.ExceptionState);
     }
   });
t2.Start();
Thread.Sleep(2000);
t2.Abort("haha");
Thread.Sleep(100);
Console.WriteLine(t2.ThreadState);

在线程方法中,我们1秒输出一次线程的状态,然后主线程休眠2秒后中断线程,略微等待一点时间, 等线程中断结束后再获取一次线程的状态。可以看到:

每一秒出现一次Running,2秒后由于线程中断处罚ThreadAbortException进入catch块,此时线程的状 态是AbortRequested,也能接受到我们中断线程时传入的状态信息,最后线程的状态为Stopped。

现在再来看看线程的Join,用于阻塞调用线程等Join的线程完成,或传入一个时间,阻塞一定的时间 :

Thread t3 = new Thread(() =>
   {
     for (int k = 0; k < 10; k++)
     {
       Thread.Sleep(100);
       Console.Write("X");
     }
     Console.WriteLine();
   });

Thread t4 = new Thread(() =>
{
   for (int k = 0; k < 10; k++)
   {
     Thread.Sleep(100);
     Console.Write("Y");
   }
   Console.WriteLine();
});

t3.Start();
t3.Join(TimeSpan.FromMilliseconds(500));
t4.Start();
Console.WriteLine();

这里可以看到,启动t3之后,我们让主线程阻塞500毫秒,这样的话t3应该已经输出若干X了,然后我 们启动t4,随后的500毫秒,t3和t4交替输出X和Y,最后500毫秒由于t3已经结束,所以只会输出Y:

最后,再来看一个有趣的问题:

我们设置一个静态字段:

static int threadstaticvalue;

然后创建两个线程来循环累加这个值:

new Thread(() =>
{
   for (int l = 0; l < 100000; l++)
   {
     threadstaticvalue++;
   }
   Console.WriteLine("from {0}: {1}", Thread.CurrentThread.Name,  threadstaticvalue);
}) { Name = "1" }.Start();

new Thread(() =>
{
   for (int m = 0; m < 200000; m++)
   {
     threadstaticvalue++;
   }
   Console.WriteLine("from {0}: {1}", Thread.CurrentThread.Name,  threadstaticvalue);
}) { Name = "2" }.Start();

运行几次输出结果如下:

虽然我们在代码中指定了两个线程分别累加值10万次和20万次,但是可以看到输出结果五花八门!这 是因为两个线程都访问了共享的静态字段,可能错开访问可能正巧同步。其实,在静态字段上加上一个 ThreadStatic特性就可以解决:

[ThreadStatic]
static int threadstaticvalue;

线程同步这个话题很大,我们下次接着讨论。

本文配套源码

凌众科技专业提供服务器租用、服务器托管、企业邮局、虚拟主机等服务,公司网站:http://www.lingzhong.cn 为了给广大客户了解更多的技术信息,本技术文章收集来源于网络,凌众科技尊重文章作者的版权,如果有涉及你的版权有必要删除你的文章,请和我们联系。以上信息与文章正文是不可分割的一部分,如果您要转载本文章,请保留以上信息,谢谢!

分享到: 更多

Copyright ©1999-2011 厦门凌众科技有限公司 厦门优通互联科技开发有限公司 All rights reserved

地址(ADD):厦门软件园二期望海路63号701E(东南融通旁) 邮编(ZIP):361008

电话:0592-5908028 传真:0592-5908039 咨询信箱:web@lingzhong.cn 咨询OICQ:173723134

《中华人民共和国增值电信业务经营许可证》闽B2-20100024  ICP备案:闽ICP备05037997号