码迷,mamicode.com
首页 > 编程语言 > 详细

C#多线程(一) 入门

时间:2014-12-30 16:55:06      阅读:293      评论:0      收藏:0      [点我收藏+]

标签:

本文你会了解如下内容:

1、计算机程序、进程、线程的概念

2、多线程的概念、为什么需要多线程、多线程的好处与坏处

3、C# 线程的一些概念与操作(创建线程、像线程中传递参数、给线程取名、前后台线程、线程优先级、异常处理)

4、线程池


一、计算机程序、进程、线程的概念

计算机程序:是计算机能识别和处理的指令集合,通常情况下是计算机操作系统可以执行的二进制文件,如在Win32系统上符合PE(Portable Executable)格式的二进制文件就可算是计算机程序。

 

进程:是计算机程序在计算机操作系统中运行的产物。一个计算机程序可以有多个进程,如一个游戏程序运行多次就会得到多个游戏程序的进程。

:在早期的操作系统(如早期的 Unix)是基于进程设计的,进程既是掌管资源的单位又是执行的单位;在现代的操作系统中,进程本身不是执行的单位,而是线程的容器,此时的进程仅仅是掌管资源的单位。

线程:是一个独立的执行流,每个线程有自己独立的线程栈。在同一进程下的线程共享进程的资源。

 

二、多线程的概念、为什么需要多线程、多线程的好处与坏处

多线程:通过软件或硬件的技术实现多个线程并发执行的技术,在通常情况下就是指一个进程中有多个线程(并发执行)的现象。

我们知道在现在主流计算机体系结构(冯诺依曼体系机构)中CPU是很宝贵的资源,我们要尽可能的提高CPU的利用率。在日常的任务操作中,有大量任务是与IO设备交互,应为IO设备的运行速度比CPU的运行速度慢好几个数量级,在需要大量IO操作的任务或程序(IO密集型)中CPU会有一段不短的时间等待IO设备处理完毕,这就造成了CPU资源的浪费。为了解决这种浪费,为了更充分的利用CPU资源,我们引入多线程技术。针对刚才的例子,我们可以通过把需要和IO设备交互的工作交给一个线程(通常是后台线程)处理,主线程继续执行其他任务,这样就解决问题了,这也就是为什么需要需要多线程技术。

 

多线程的好处

1、提高了CPU的利用率

2、提升了程序的效率

多线程的坏处

1、增加了程序的复杂度(创建线程不复杂、复杂的是线程间的协调工作),可能导致一些很难调试的BUG

2、比单线程程序消耗更多的资源(每个线程有独立的线程栈,这是需要资源滴)

建议

1、将多线程逻辑封装到一个可重用的类库中,这个类库可以被充分的测试。最好不要将多线程处理逻辑和业务处理逻辑耦合得太紧,这样做是在给自己挖坑 技术分享

 

三、C# 线程的一些概念与操作

光说不练假把式,先来看个例子(为了节省文章版幅,因此代码有时候采用缩行处理)

 

例1:创建线程

using System;
using System.Threading;

class App
{
    static void Main()
    {
        Thread t = new Thread(WriteY);
        t.Start();
        while(true) {Console.Write("x");}
    }
    
    static void WriteY()
    {
        while(true) {Console.Write("y");}
    }
}

编译: csc 1.cs

运行 1.exe > result.txt

上面的 “>” 是一个DOS运算符,含义是将 1.exe 打印的字符写入到 result.txt 文本中

效果:

技术分享

引用 Thread in C# 中的一幅图

技术分享

 

 

 

刚才我们说每个线程有独立的线程栈,我们写代码验证下

using System;
using System.Threading;

// 每个线程内的变量互相不影响,CLR为每个线程在堆上分配独立的线程栈控件
class App
{
    static void Main()
    {
        new Thread(Go).Start();
        Go();
    }
    
    static void Go()
    {
        for(int cycles = 0; cycles<5; cycles++) {Console.Write("?");}
    }
}

运行效果:??????????

10 个问号,不是5个问号,正好验证了我们的猜测。

 

 

当线程引用公有变量(全局变量)时它们会共享此公有变量的数据,看下例:

using System;
using System.Threading;
// 实例字段和实例方法
class App
{
    bool done;
    static void Main()
    {
        App app = new App();
        new Thread(app.Go).Start();
        app.Go();
    }
    
    void Go()
    {
        if(!done){done = true; Console.WriteLine("This Only Print Once");}
    }
}

运行效果: This Only Print Once

貌似这个程序得到了我们要的效果,其实这样做是存在打印出两次的风险的(虽然概率极小),为了让出现打印两次的概念变大许多,我们改变以下 done = true; 和Console.WriteLine("This Only Print Once"); 的次序变为:

void Go()
{
    if(!done){Console.WriteLine("This Only Print Once");done = true; }
}

运行结果变为:

This Only Print Once
This Only Print Once

 

打印了两次,这并不是我们想要的结果。通过这个例子,我们引入线程安全的概念(其实这是一个非线程安全的例子)即在多线程情况下,每次运行结果和单线程运行的结果是一样的,相关变量的值也是在预期范围内的,这样的情况成为线程安全,反之称为非线程安全(说白了,线程安全,就是程序跑出的结果和你猜想的一致,非线程安全就是和你想的不一致)

 

 

在C#中解决上面非线程安全问题的最简单的方式就是用 lock 语句锁住多线程交互的地方,看代码:

 

using System;
using System.Threading;

class App
{
    static bool done;
    static object _locker = new object();            
    static void Main()
    {
        new Thread(Go).Start();
        Go();
    }
    
    static void Go()
    {
        lock(_locker)
        {
            if(!done) {Console.WriteLine("This Only Print Once");done = true;}
        }
    }    
}

运行结果:This Only Print Once

注意

1、线程间共享公有数据是多线程复杂性以及产生难以发现BUG的主要原因,尽管多线程之间经常需要共享公共数据,但尽量使共享数据交互的代码尽量简单吧 技术分享

2、通过lock语句每次只有一个线程进入临界区,其余线程被挡在临界区外(或等待或被阻塞Blocked)直到获取到lock的锁对象。

3、lock 语句是比较耗资源的,lock语句锁住的范围最好尽量的小。考虑一个极端的情况,在一个多线程程序中用lock语句锁住的范围是整个程序的执行范围,这是神马情况?这种情况不就是和单线程执行效果一样了么,那还用毛线多线程技术和lock语句呀,对吧?!

 

 

Join 与 Sleep语句

你可以通过Join语句实现线程A等待线程B执行完的功能,看代码:

using System;
using System.Threading;

class App
{
    static void Main()
    {
        Thread t = new Thread(() =>
        {
            for(int i = 0; i< 1000; i++) {Console.Write("y ");}
        });                        
        t.Start();        
        t.Join();        // 主线程等待 线程t执行完毕再结束    
        Console.WriteLine("Thread t has ended!");
    }
}

编译 :csc 10_join.cs

运行 : 10_join.exe > joinResult.txt

程序执行效果:

技术分享

其实本例的t.Join(); 加不加效果都一样,原因是用 Thread 创建的线程是前台线程,程序要等到所有前台线程执行完毕后才会退出,这个下面会谈到。

Thread.Sleep 暂停当前线程指定时间

Thread.Sleep(TimeSpan.FromHours(1));    // 暂停1小时
Thread.Sleep(500);    // 暂停 500 毫秒

注意

1、Thread.Sleep(0) 或 Thread.Yield() 表示主动放弃当前线程执行权,把CPU资源让给别的线程。Yield(有放弃、让步、屈服之意)

 

 

ThreadStart委托与 ParameterizedThreadStart 委托

先看看MSDN上的定义:

public delegate void ThreadStart() // 无参

public delegate void ParameterizedThreadStart(Object obj)  // 带参数,可以向线程中传递数据,但注意这里只能用Object,因此涉及到装箱拆箱操作

初始化委托有四种方法(原始方式、方法方式、匿名方法方式、Lambda 方式)详见 类库探源——System.Delegate 

using System;
using System.Threading;

class App
{
    static void Main()
    {        
        Thread t = new Thread(new ThreadStart(WriteY));     // 这是原始的方法
        /* 还可以
        Thread t = new Thread(WriteY);        // 方法方式
        Thread t = new Thread(delegate(){while(true) {Console.Write("y");}});    // 匿名方法
        Thread t = new Thread(() => {while(true) {Console.Write("y");}});    // Lambda 表达式        
        */
        Console.WriteLine(t.IsBackground);        // 用 Thread 创建的线程是前台线程 结果是 False
         t.Start();
        while(true) {Console.Write("x");}
    }
    
    static void WriteY()
    {
        while(true) {Console.Write("y");}
    }
}

 

运行结果:

技术分享

 

 

向线程中传递数据

首先我们可以用 ParameterizedThreadStart 委托传递参数,看代码:

using System;
using System.Threading;

class App
{
    static void Main()
    {
        string str = "Contents";
        var t = new Thread(Invoke);
        t.Start(str);    // 传参
    }    
    static void Invoke(object str)
    {
        Console.WriteLine(str);
    }    
}

上面的代码可以用 Lambda 表达式写得更精练

static void Main()
{
    string str = "Contents";
    new Thread((obj) =>{Console.WriteLine(obj);}).Start(str);
}

 

第二种方法用匿名方法(或Lambda表达式)调用一个普通方法变通解决:

using System;
using System.Threading;

class App
{
    static void Main()
    {
        Thread t = new Thread(delegate(){WriteText("hello Thread Param");});
        //可用Lambda表达式 var t = new Thread(() =>WriteText("hello Thread Param"));        
        t.Start();
    }    
    static void WriteText(string txt)
    {
        Console.WriteLine(txt);
    }
}

 

 

Lambda 表达式值捕获问题

如我们所见 Lambda 表达式是向线程传值的最强大的方式,但是你必须小心值捕获(captured variables)问题,也有人把这个问题称为闭包下值的问题,看代码:

using System;
using System.Threading;

class App
{
    static void Main()
    {
        for(int i = 0; i < 10; i++)
        {
            new Thread(() => Console.Write(i)).Start();
        }
    }
}

运行几次的效果:

技术分享

可以看出每次都不一样技术分享,也没有一次值为 0123456789 这是为什么呢?

原因是在循环指向过程中的变量 i 指向了相同的内存位置(i variable refers to the same memory location throughout the loop’s lieftime.)每个线程获取到i的值不会那么巧正好是 0123456789的顺序

解决方法:用个临时变量存储i

int temp = i;
new Thread(() => Console.Write(temp)).Start();

效果:

技术分享

每次都是 0123456789

再用更简单例子来说明:

string text = "t1";
var t1 = new Thread(() =>Console.WriteLine(text));

string text = "t2";
var t2 = new Thread(() =>Console.WriteLine(text));

t1.Start();
t2.Start();

结果是打印 两个 t2

 

给线程取名

给线程命名在调试的时候很有用,在VS下可以查看线程名字

Thread.CurrentThread 获取当前正在运行的线程

using System;
using System.Threading;

class App
{
    static void Main()
    {
        Thread.CurrentThread.Name = "Main Thread";
        var worker = new Thread(Go);
        worker.Name = "Worker Thread";
        worker.Start();    // 另取线程调用Go
        Go();    // 主线程中调用Go
    }
    
    static void Go()
    {
        Console.WriteLine("Hello from " + Thread.CurrentThread.Name);
    }
}

运行效果:

技术分享

 

 

前台线程与后台线程

用 Thread 类创建的线程默认是前台线程,应用程序的所有前台线程执行完后才结束,如何特殊设置(如Join)前台线程结束后,后台线程也会终止因为程序都terminate 了嘛 技术分享

看下刚才Join的例子,我们将用后台线程演示,看代码:

using System;
using System.Threading;

class App
{
    static void Main()
    {
        Thread t = new Thread(() =>
        {
            for(int i = 0; i< 1000; i++) {Console.Write("y ");}
        });            
        t.IsBackground = true;
        t.Start();        
        
        Console.WriteLine("Thread t has ended!");
    }
}

运行2次效果:

技术分享

第一次执行打印一个y 第二次执行打印一个y ,反正都没打印完

现在用 Join 语句阻塞下

using System;
using System.Threading;

class App
{
    static void Main()
    {
        Thread t = new Thread(() =>
        {
            for(int i = 0; i< 1000; i++) {Console.Write("y ");}
        });            
        t.IsBackground = true;
        t.Start();        
        t.Join();
        Console.WriteLine("Thread t has ended!");
    }
}

效果:

技术分享

后台线程执行完了。

注意

1、Thread 创建的线程默认是前台线程

2、线程池创建的线程默认是后台线程

3、线程的前后台状态与线程的优先级没有关系

 

线程优先级

public enum ThreadPriority{Lowest,BelowNormal,Normal,AboveNormal,Highest}

 

异常处理

参见 类库探源——System.Exception 中第四和第五小节

 

未完

本系列参考Joseph Albaharis Thread in C#

 

C#多线程(一) 入门

标签:

原文地址:http://www.cnblogs.com/Aphasia/p/4193778.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!