本篇体验:如何传递数据给线程,如何给线程命名,线程的异常处理,线程池。实在是太基础的部分。
□ 传递数据给线程
※ 使用Lambda表达式
monospace; width: 100%; margin: 0em; background-color: #f0f0f0"> class Program
{static void Main(string[] args){Thread t = new Thread(() => Say("hello", "world"));t.Start();}static void Say(string msg, string msg1){Console.WriteLine("第一个参数值是:"+msg);
Console.WriteLine("第二个参数值是:" + msg1);
}}
使用Lambda表达式需要注意的一个问题。
class Program
{static void Main(string[] args){for (int i = 0; i < 10; i++){new Thread(() => Console.WriteLine("当前线程#" + Thread.CurrentThread.ManagedThreadId + "输出的值是:" + i)).Start();}}}
说明,有些线程共享了局部变量i。如何解决线程共享栈变量的问题呢?只需要在每次遍历循环的时候,把i赋值给一个临时变量,再打印临时变量,不直接打印栈变量i。
class Program
{static void Main(string[] args){for (int i = 0; i < 10; i++){int temp = i;
new Thread(() => Console.WriteLine("当前线程#" + Thread.CurrentThread.ManagedThreadId + "输出的值是:" + temp)).Start();}}}
打印的值没有重复的。
※ 使用线程的实例方法Start
class Program
{static void Main(string[] args){Thread t = new Thread(Say);
t.Start("hello");
}static void Say(object msg){string str = (string) msg;Console.WriteLine(str);}}
之所以可以这样做,是因为Thread的构造函数可以接收2种类型的形参。
public delegate void ThreadStart();public delegate void ParameterizedThreadStart (object obj);
所有符合ParameterizedThreadStart这个委托定义的方法,必须有一个object类型的参数,然后在实例方法Start中传递参数。使用这种方式传递参数的弊端是:
1、只能传递一个参数
2、在方法体中,每次都要对object类型进行转换,拆箱
□ 给线程命名
class Program
{static void Main(string[] args){Thread.CurrentThread.Name = "主线程";
Thread t = new Thread(Say);
t.Name = "其它工作线程";
t.Start();Say();}static void Say(){Console.WriteLine("我的名字是:" + Thread.CurrentThread.Name);
}}
通过Name属性可以设置或获取当前线程和实例线程的名称。
□ 线程的异常处理
一个线程无法捕获另外线程的异常。
class Program
{static void Main(string[] args){try
{new Thread(Say).Start();
}catch (Exception)
{Console.WriteLine("有异常");
}}static void Say(){throw null;}}
以上,在主线程的catch语句块中,无法捕获另外一个线程的异常。
实际上,一个线程的异常必须在该线程方法内捕获。
class Program
{static void Main(string[] args){new Thread(Say).Start();
}static void Say(){try
{throw null;}catch (Exception)
{Console.WriteLine("捕获到异常了");
}}}
□ 线程池
当创建一个线程,会用几十到几百毫秒的时间创建该线程的栈,而且,在默认情况下,每个线程需要1M的栈空间。线程池做到了共享和重复使用线程,性能得以提高。线程池还可以设置允许的最多线程数,一旦达到这个极限值,多余的线程需要排队,等待线程池中的线程执行结束再进入。
线程池的默认的最大线程数因计算机不同而异。在.NET 4.0及其以后的版本中,在2位计算机最大线程数为1023个,64位为32768;在.NET3.5中,线程池最大线程数是250个;在.NET2.0中,线程池最大线程数为25个。当然,可以通过TreadPool.SetMaxThreads来设置线程池的最大线程数,也可以通过ThreadPool.SetMinThreads来设置最小线程数。
※ 通过TPL进入线程池
TPL,Task Parallel Library,是一个处理并行任务的一个类库。
class Program
{static void Main(string[] args){Task tast = Task.Factory.StartNew(Say);tast.Wait();}static void Say(){Console.WriteLine("hello,我已经是线程池中的线程了");
}}
使用System.Net.WebClient的实例方法DownloadString方法下载某个网页,使用泛型Task<T>来处理。
class Program
{static void Main(string[] args){Task<string> task = Task.Factory.StartNew<string>(() => DownloadString("http://www.baidu.com"));Console.WriteLine("Task在工作呢,我玩会啊~~");
Console.WriteLine("Task在工作呢,我玩会啊~~");
Console.WriteLine("Task在工作呢,我玩会啊~~");
string result = task.Result;
Console.WriteLine(result);}static string DownloadString(string uri){using (var wc = new System.Net.WebClient()){return wc.DownloadString(uri);
}}}
※ 不通过TPL进入线程池
class Program
{static void Main(string[] args){ThreadPool.QueueUserWorkItem(Say);ThreadPool.QueueUserWorkItem(Say, 123);Console.ReadLine();}static void Say(object data){Console.WriteLine("我来自线程池,我获取到的数据是:" + data);
}}
※ 使用委托进入线程池
class Program
{static void Main(string[] args){Func<string, int> method = GetLength;IAsyncResult ia = method.BeginInvoke("test", null, null);Console.WriteLine("线程池的线程在工作者呢,我先玩会~");
int result = method.EndInvoke(ia);
Console.WriteLine("test的长度为:" + result);
}static int GetLength(string s){return s.Length;
}}
把方法赋值给委托变量,CLR会创建一个线程池中的线程。
线程系列包括:
参考资料:http://www.albahari.com/threading