c#多线程编程基础
无论您是为具有单个处理器的计算机还是为具有多个处理器的计算机进行开发，您都希望应用程序为用户提供最好的响应性能，即使应用程序当前正在完成其他工作。要使应用程序能够快速响应用户操作，同时在用户事件之间或者甚至在用户事件期间利用处理器，最强大的方式之一是使用多线程技术。
多线程：线程是程序中一个单一的顺序控制流程.在单个程序中同时运行多个线程完成不同的工作,称为多线程。如果某个线程进行一次长延迟操作， 处理器就切换到另一个线程执行。这样，多个线程的并行(并发)执行隐藏了长延迟，提高了处理器资源利用率，从而提高了整体性能。多线程是为了同步完成多项任务，不是为了提高运行效率，而是为了提高资源使用效率来提高系统的效率
一、进程与线程
进程,是操作系统进行资源调度和分配的基本单位。是由进程控制块、程序段、数据段三部分组成。一个进程可以包含若干线程(thread)，线程可以帮助应用程序同时做几件事(比 如一个线程向磁盘写入文件，另一个则接收用户的按键操作并及时做出反应，互相不干扰)，在程序被运行后中，系统首先要做的就是为该程序进程建立一个默认线程，然后程序可 以根据需要自行添加或删除相关的线程。它是可并发执行的程序。在一个数据集合上的运行过程，是系统进行资源分配和调度的一个独立单位，也是称活动、路径或任务，它有两方面性质：活动性、并发性。进程可以划分为运行、阻塞、就绪三种状态，并随一定条件而相互转化：就绪--运行，运行--阻塞，阻塞--就绪。
线程(thread)，线程是cpu调度和执行的最小单位。有时被称为轻量级进程(lightweight process，lwp)，是程序执行流的最小单元。一个标准的线程由线程id，当前指令指针(pc)，寄存器集合和堆栈组成。另外，线程是进程中的一个实体，是被系统独立调度和分派的基本单位，线程自己不拥有系统资源，只拥有一点在运行中必不可少的资源，但它可与同属一个进程的其它线程共享进程所拥有的全部资源。一个线程可以创建和撤消另一个线程，同一进程中的多个线程之间可以并发执行。由于线程之间的相互制约，致使线程在运行中呈现出间断性。线程也有就绪、阻塞和运行三种基本状态。
主线程，进程创建时，默认创建一个线程，这个线程就是主线程。主线程是产生其他子线程的线程，同时，主线程必须是最后一个结束执行的线程，它完成各种关闭其他子线程的操作。尽管主线程是程序开始时自动创建的，它也可以通过thead类对象来控制，通过调用currentthread方法获得当前线程的引用
多线程的优势：进程有独立的地址空间，同一进程内的线程共享进程的地址空间。启动一个线程所花费的空间远远小于启动一个进程所花费的空间，而且，线程间彼此切换所需的时间也远远小于进程间切换所需要的时间。
二、多线程优点
1、提高应用程序响应。这对图形界面的程序尤其有意义，当一个操作耗时很长时，整个系统都会等待这个操作，此时程序不会响应键盘、鼠标、菜单的操作，而使用多线程技术，将耗时长的操作（time consuming）置于一个新的线程，可以避免这种尴尬的情况。
2、使多cpu系统更加有效。操作系统会保证当线程数不大于cpu数目时，不同的线程运行于不同的cpu上。
3、改善程序结构。一个既长又复杂的进程可以考虑分为多个线程，成为几个独立或半独立的运行部分，这样的程序会利于理解和修改。。
多线程尽管优势明显，但是线程并发冲突、同步以及管理跟踪，可能给系统带来很多不确定性，这些必须引起足够重视。
废话不多说开始我们的多线程之旅。
三、多线程的应用场合：
简单总结了一下，一般有两种情况：
1）多个线程，完成同类任务，提高并发性能
2）一个任务有多个独立的步骤，多个线程并发执行各子任务，提高任务处理效率
四、案例--搬运工
在我们现实生活中，经常看到这样的场景。有一堆货物，有几个搬运工负责将货物搬运到指定地点。但是搬运工能力不同，有人一次能搬多箱，有人走路比较慢，搬运一趟的时间间隔比较长。搬运工，各自搬运，无先后，互不干扰。我们如何在程序中实现这种场景呢？
案例分析：
这个就是最简单的多线程的实际案例。每个人相当于一个线程，并发执行。当货物搬运完毕后，每个线程自动停止。这里暂时不考虑死锁情况。
案例代码：
using system;
using system.collections.generic;
using system.linq;
using system.text;
using system.threading;
namespace mutithreadsample.transport
{
/// <summary>
/// 搬运工
/// </summary>
public class mover
{
/// <summary>
/// 总数
/// </summary>
public static int goodstotal { get; set; }
/// <summary>
/// 间隔时间
/// </summary>
public static int intervaltime { get; set; }
/// <summary>
/// 名称
/// </summary>
public string name { get; set; }
/// <summary>
/// 单位时间搬运量
/// </summary>
public int laboramount { get; set; }
/// <summary>
/// 搬运
/// </summary>
public void move()
{
while (goodstotal > 0)
{
goodstotal -= laboramount;
console.writeline("搬运者：{0} 于 {1} 搬运货物 {2}",this.name,datetime.now.millisecond,this.laboramount);
thread.sleep(intervaltime);
console.writeline("搬运者：{0} continue",this.name);
}
}
/// <summary>
/// 搬运
/// </summary>
/// <param name="interval">时间间隔</param>
public void move(object interval)
{
int tempinterval = 0;
if (!int.tryparse(interval.tostring(), out tempinterval))
{
tempinterval = intervaltime;
}
while (goodstotal > 0)
{
goodstotal -= laboramount;
console.writeline("搬运者：{0} 于 {1} 搬运货物 {2}", this.name, datetime.now.millisecond, this.laboramount);
thread.sleep(tempinterval);
}
}
}
}
测试：
using system;
using system.collections.generic;
using system.linq;
using system.text;
using system.threading;
namespace mutithreadsample.transport
{
/// <summary>
/// 测试搬运
/// </summary>
public class testmove
{
/// <summary>
/// 搬运
/// </summary>
public static void move()
{
//测试搬运工
mover.goodstotal = 200;
mover.intervaltime = 10;
mover m1 = new mover() { name = "tom", laboramount = 5 };
mover m2 = new mover() { name = "jim", laboramount = 10 };
mover m3 = new mover() { name = "lucy", laboramount = 20 };
list<mover> movers = new list<mover>();
movers.add(m1);
//movers.add(m2);
//movers.add(m3);
if (movers != null && movers.count > 0)
{
foreach (mover m in movers)
{
thread thread = new thread(new threadstart(m.move));
thread.start();
}
}
//main thread continue
// validate thread.sleep()
//int i =0;
//int j = 0;
//while (i < 10)
//{
// while(j<10000000)
// {
// j++;
// }
// console.writeline("currentthread:{0}", thread.currentthread.name);
// i++;
//}
}
/// <summary>
/// 搬运
/// </summary>
public static void movewithparamthread()
{
//测试搬运工
mover.goodstotal = 1000;
mover.intervaltime = 100;
mover m1 = new mover() { name = "tom", laboramount = 5 };
mover m2 = new mover() { name = "jim", laboramount = 10 };
mover m3 = new mover() { name = "lucy", laboramount = 20 };
list<mover> movers = new list<mover>();
movers.add(m1);
movers.add(m2);
movers.add(m3);
if (movers != null && movers.count > 0)
{
foreach (mover m in movers)
{
thread thread = new thread(new parameterizedthreadstart(m.move));
thread.start(10);
}
}
}
}
}
通过案例我们也接触了thread，下面我们将详细介绍thread的功能。
五、thread
创建并控制线程，设置其优先级并获取其状态。
常用方法：
start()
导致操作系统将当前实例的状态更改为 threadstate.running。
一旦线程处于 threadstate.running 状态，操作系统就可以安排其执行。 线程从方法的第一行（由提供给线程构造函数的 threadstart 或 parameterizedthreadstart 委托表示）开始执行。线程一旦终止，它就无法通过再次调用 start 来重新启动。
thread.sleep()
调用 thread.sleep 方法会导致当前线程立即阻止，阻止时间的长度等于传递给 thread.sleep 的毫秒数，这样，就会将其时间片中剩余的部分让与另一个线程。 一个线程不能针对另一个线程调用 thread.sleep。
interrupt()
中断处于 waitsleepjoin 线程状态的线程。
suspend和resume（已过时）
挂起和继续
在 .net framework 2.0 版中，thread.suspend 和 thread.resume 方法已标记为过时，并将从未来版本中移除。
abort()
方法用于永久地停止托管线程。一旦线程被中止，它将无法重新启动。
join()
阻塞调用线程，直到某个线程终止时为止。
threadpriority（优先级）
指定 thread 的调度优先级。
threadpriority 定义一组线程优先级的所有可能值。线程优先级指定一个线程相对于另一个线程的相对优先级。
每个线程都有一个分配的优先级。在运行库内创建的线程最初被分配 normal 优先级，而在运行库外创建的线程在进入运行库时将保留其先前的优先级。可以通过访问线程的 priority 属性来获取和设置其优先级。
根据线程的优先级调度线程的执行。用于确定线程执行顺序的调度算法随操作系统的不同而不同。操作系统也可以在用户界面的焦点在前台和后台之间移动时动态地调整线程的优先级。
一个线程的优先级不影响该线程的状态；该线程的状态在操作系统可以调度该线程之前必须为 running。
六、创建线程方式
通过搬运工案例我们能够了解线程的工作原理，也明白了线程的创建方式。
其实在c#中创建线程有几种方式，这里给大家举几个常用例子，如下：
using system;
using system.threading;
namespace mutithreadsample
{
/// <summary>
/// 创建线程的方式
/// </summary>
class createthread
{
/// <summary>
/// 不带参数的委托
/// </summary>
public void createthreadwiththreadstart()
{
thread thread = new thread(new threadstart(threadcallback));
thread.start();
}
/// <summary>
/// 带参数的委托
/// </summary>
public void createthreadwithparamthreadstart()
{
thread thread = new thread(new parameterizedthreadstart(threadcallbackwithparam));
thread.start();
}
/// <summary>
/// 匿名函数
/// </summary>
public void createthreadwithanonymousfunction()
{
thread thread = new thread(delegate()
{
console.writeline("进入子线程1");
for (int i = 1; i < 4; ++i)
{
thread.sleep(50);
console.writeline("\t+++++++子线程1+++++++++");
}
console.writeline("退出子线程1");
});
thread.start();
}
/// <summary>
/// 直接赋值委托
/// </summary>
public void createthreadwithcallback()
{
thread _hthread = new thread(threadcallback);
_hthread.start();
}
/// <summary>
/// 无参数的方法调用
/// </summary>
public void threadcallback()
{
// do something
}
/// <summary>
/// 带参数的方法
/// </summary>
/// <param name="obj"></param>
public void threadcallbackwithparam(object obj)
{
// do something
}
}
}
时钟线程
使用 timercallback 委托指定希望 timer 执行的方法。 计时器委托在构造计时器时指定，并且不能更改。 此方法不在创建计时器的线程上执行，而是在系统提供的 threadpool 线程上执行。创建计时器时，可以指定在第一次执行方法之前等待的时间量（截止时间）以及此后的执行期间等待的时间量（时间周期）。 可以使用 change 方法更改这些值或禁用计时器。
using system;
using system.threading;
class timerexample
{
static void main()
{
// create an event to signal the timeout count threshold in the
// timer callback.
autoresetevent autoevent = new autoresetevent(false);
statuschecker statuschecker = new statuschecker(10);
// create an inferred delegate that invokes methods for the timer.
timercallback tcb = statuschecker.checkstatus;
// create a timer that signals the delegate to invoke
// checkstatus after one second, and every 1/4 second
// thereafter.
console.writeline("{0} creating timer.\n",
datetime.now.tostring("h:mm:ss.fff"));
timer statetimer = new timer(tcb, autoevent, 1000, 250);
// when autoevent signals, change the period to every
// 1/2 second.
autoevent.waitone(5000, false);
statetimer.change(0, 500);
console.writeline("\nchanging period.\n");
// when autoevent signals the second time, dispose of
// the timer.
autoevent.waitone(5000, false);
statetimer.dispose();
console.writeline("\ndestroying timer.");
}
}
class statuschecker
{
private int invokecount;
private int maxcount;
public statuschecker(int count)
{
invokecount = 0;
maxcount = count;
}
// this method is called by the timer delegate.
public void checkstatus(object stateinfo)
{
autoresetevent autoevent = (autoresetevent)stateinfo;
console.writeline("{0} checking status {1,2}.",
datetime.now.tostring("h:mm:ss.fff"),
(++invokecount).tostring());
if(invokecount == maxcount)
{
// reset the counter and signal main.
invokecount = 0;
autoevent.set();
}
}
}
七、前台线程和后台线程
.net的公用语言运行时（common language runtime，clr）能区分两种不同类型的线程：前台线程和后台线程。这两者的区别就是：应用程序必须运行完所有的前台线程才可以退出；而对于后台线程，应用程序则可以不考虑其是否已经运行完毕而直接退出，所有的后台线程在应用程序退出时都会自动结束。
一个线程是前台线程还是后台线程可由它的isbackground属性来决定。这个属性是可读又可写的。它的默认值为false，即意味着一个线程默认为前台线程。
我们可以将它的isbackground属性设置为true，从而使之成为一个后台线程。下面的例子是一个控制台程序，程序一开始便启动了10个线程，每个线程运行5秒钟时间。由于线程的isbackground属性默认为false，即它们都是前台线程，所以尽管程序的主线程很快就运行结束了，但程序要到所有已启动的线程都运行完毕才会结束。示例代码如下例子中的test（）所示
using system;
using system.threading;
namespace mutithreadsample.threadtype
{
class threadtypetest
{
/// <summary>
/// 测试前台线程
/// </summary>
public static void test()
{
for (int i = 0; i < 10; i++)
{
thread thread = new thread(new threadstart(threadfunc));
thread.start();
}
}
/// <summary>
/// 测试后台线程
/// </summary>
public static void testbackgroundthread()
{
for (int i = 0; i < 10; i++)
{
thread thread = new thread(new threadstart(threadfunc));
thread.isbackground = true;
thread.start();
}
}
public static void threadfunc()
{
thread.sleep(0);
datetime start = datetime.now;
while ((datetime.now - start).seconds < 20);//可以停顿的时间长一点，效果更加明显
}
}
}
接下来我们对上面的代码进行略微修改，将每个线程的isbackground属性都设置为true，则每个线程都是后台线程了。那么只要程序的主线程结束了，整个程序也就结束了。示例代码如代码中的testbackgroundthread（）。
这个例子直接创建一个控制台程序即可检验。
前台和后台线程的使用原则
既然前台线程和后台线程有这种差别，那么我们怎么知道该如何设置一个线程的isbackground属性呢？下面是一些基本的原则：对于一些在后台运行的线程，当程序结束时这些线程没有必要继续运行了，那么这些线程就应该设置为后台线程。比如一个程序启动了一个进行大量运算的线程，可是只要程序一旦结束，那个线程就失去了继续存在的意义，那么那个线程就该是作为后台线程的。而对于一些服务于用户界面的线程往往是要设置为前台线程的，因为即使程序的主线程结束了，其他的用户界面的线程很可能要继续存在来显示相关的信息，所以不能立即终止它们。这里我只是给出了一些原则，具体到实际的运用往往需要编程者的进一步仔细斟酌。
八、总结
这一章主要介绍多线程技术的基本知识。涉及多线程的具体应用，包括预防死锁、线程同步、线程池等，在今后的文章会涉及到。