-
C#线程 入门-创建和启动线程
创建和启动线程
正如我们在简介中所看到的,线程是使用Thread类的构造函数创建的,并传入ThreadStart委托,该委托指示应从何处开始执行。定义ThreadStart委托的方法如下:
public delegate void ThreadStart();
在线程上调用Start,然后将其设置为运行。线程继续执行,直到其方法返回为止,此时线程结束。这是使用扩展的C#语法创建TheadStart委托的示例:
1 class ThreadTest 2 { 3 static void Main() 4 { 5 Thread t = new Thread (new ThreadStart (Go)); 6 7 t.Start(); // Run Go() on the new thread. 8 Go(); // Simultaneously run Go() in the main thread. 9 } 10 11 static void Go() 12 { 13 Console.WriteLine ("hello!"); 14 } 15 }
在此示例中,线程t在主线程调用Go()的同一时间执行Go()。结果是两个接近即时的问候。
通过仅指定一个方法组,并允许C#推断ThreadStart委托,可以更方便地创建线程:
Thread t = new Thread (Go); //无需显式使用ThreadStart
另一个快捷方式是使用lambda表达式或匿名方法:
static void Main() { Thread t = new Thread ( () => Console.WriteLine ("Hello!") ); t.Start(); }
将数据传递给线程
将参数传递给线程的target方法的最简单方法是执行一个lambda表达式,该表达式使用所需的参数调用该方法:
1 static void Main() 2 { 3 Thread t = new Thread ( () => Print ("Hello from t!") ); 4 t.Start(); 5 } 6 7 static void Print (string message) 8 { 9 Console.WriteLine (message); 10 }
使用这种方法,您可以将任意数量的参数传递给该方法。您甚至可以将整个实现包装在多语句lambda中:
new Thread (() => { Console.WriteLine ("I'm running on another thread!"); Console.WriteLine ("This is so easy!"); }).Start();
您可以使用匿名方法在C#2.0中几乎轻松地执行相同的操作:
1
2
3
4
|
new Thread ( delegate () { ... }).Start(); |
另一种技术是将参数传递给Thread的Start方法:
1
2
3
4
5
6
7
8
9
10
11
|
static void Main() { Thread t = new Thread (Print); t.Start ( "Hello from t!" ); } static void Print ( object messageObj) { string message = ( string ) messageObj; // We need to cast here Console.WriteLine (message); } |
之所以可行,是因为Thread的构造函数被重载为接受两个委托之一:
1
2
|
public delegate void ThreadStart(); public delegate void ParameterizedThreadStart ( object obj); |
ParameterizedThreadStart的局限性在于它仅接受一个参数。而且由于它是object类型的,因此通常需要强制转换。
Lambda表达式和捕获的变量
如我们所见,lambda表达式是将数据传递到线程的最强大的方法。但是,您必须小心在启动线程后意外修改捕获的变量,因为这些变量是共享的。例如,考虑以下内容:
1
2
|
for ( int i = 0; i < 10; i++) new Thread (() => Console.Write (i)).Start(); |
输出是不确定的!这是一个典型的结果:
0223557799
问题在于,i变量在循环的整个生命周期中都指向相同的内存位置。因此,每个线程都会在变量上调用Console.Write,该变量的值可能会随着运行而改变!
这类似于我们在C#4.0的第八章“捕获变量”中描述的问题。问题不在于多线程,而是与C#捕获变量的规则有关(在for和foreach循环的情况下这是不希望的)。
解决方案是使用如下临时变量:
1
2
3
4
5
|
for ( int i = 0; i < 10; i++) { int temp = i; new Thread (() => Console.Write (temp)).Start(); } |
现在,可变温度是每个循环迭代的局部变量。因此,每个线程捕获一个不同的内存位置,这没有问题。我们可以通过以下示例更简单地说明早期代码中的问题:
1
2
3
4
5
6
7
8
|
string text = "t1" ; Thread t1 = new Thread ( () => Console.WriteLine (text) ); text = "t2" ; Thread t2 = new Thread ( () => Console.WriteLine (text) ); t1.Start(); t2.Start(); |
因为两个lambda表达式都捕获相同的文本变量,所以t2被打印两次
t2
t2