1. 线程的异常处理
我们经常会遇到一个场景，开启了多个线程，其中一个线程报错，导致整个程序崩溃。这并不是我们想要的，我需要的结果是，其中一个线程报错，默默的记录下，其它线程正常进行，保证程序整体可以走下来。
解决方案：给函数体加try-catch，只让报错线程异常，其它线程可以正常进行。
private void button7_Click(object sender, EventArgs e)
{
Stopwatch watch = new Stopwatch();
watch.Start();
Console.WriteLine("----------------- 八.线程的特殊处理 --------------------------");
Console.WriteLine("----------------- button7_Click 开始 主线程id为：{0} --------------------------", Thread.CurrentThread.ManagedThreadId);
try
{ TaskFactory taskFactory = new TaskFactory();
List<Task> taskList = new List<Task>(); #region 01-异常处理
{
for (int i = ; i < ; i++)
{
string name = string.Format("button_Click{0}", i);
Action<object> act = t =>
{
try
{
//模拟报错
if (t.ToString().Equals("button_Click2"))
{
throw new Exception(string.Format("{0} 执行失败", t));
}
Console.WriteLine("{0} 执行成功", t);
}
catch (Exception ex)
{
Console.WriteLine(ex.Message);
}
};
Task task = taskFactory.StartNew(act, name);
taskList.Add(task);
}
//线程等待
Task.WaitAll(taskList.ToArray());
}
#endregion }
catch (AggregateException aes)
{
foreach (var item in aes.InnerExceptions)
{
Console.WriteLine(item.Message);
}
}
catch (Exception ex)
{
Console.WriteLine(ex.Message);
} watch.Stop();
Console.WriteLine("----------------- button7_Click 结束 主线程id为：{0} 总耗时：{1}--------------------------", Thread.CurrentThread.ManagedThreadId, watch.ElapsedMilliseconds); }
运行结果：
2. 线程的取消
线程不能主动取消，只能通过信号量的形式进行检查，接到取消指令后，后续的线程都将取消。
{
//Task不能主动取消，只能通过信号量检查的方式
CancellationTokenSource cts = new CancellationTokenSource();
for (int i = ; i < ; i++)
{
string name = string.Format("button_Click{0}", i);
Action<object> act = t =>
{
try
{
Thread.Sleep();
//模拟报错
if (t.ToString().Equals("button_Click2"))
{
throw new Exception(string.Format("{0} 执行失败", t));
}
if (cts.IsCancellationRequested)
{
Console.WriteLine("{0} 放弃执行", t);
}
else
{
Console.WriteLine("{0} 执行成功", t);
}
}
catch (Exception ex)
{
cts.Cancel(); //凡是在 button_Click2 的执行线程后执行的，均被放弃了执行
Console.WriteLine(ex.Message);
}
};
Task task = taskFactory.StartNew(act, name, cts.Token);
taskList.Add(task);
}
//线程等待
Task.WaitAll(taskList.ToArray());
}
运行结果：
3. 多线程临时变量
{
for (int i = ; i < ; i++)
{
int k = i;
Action act = () =>
{
Console.WriteLine(k); //0,1，2,3,4 不一定按照顺序
Console.WriteLine(i); //全为5
};
act.BeginInvoke(null, null);
}
}
4. 线程安全
当多个线程同时操控一个全局变量时，需要加锁，来保证线程安全。其中锁变量为 私有的静态object变量。eg： private static object btnThreadCore_Click_Lock = new object();
{
for (int i = ; i < ; i++)
{
Task task = taskFactory.StartNew(() =>
{
//只有方法外的变量需要加锁
int k = ;
lock (btnThreadCore_Click_Lock)
{
this.TotalCount += ;
}
});
taskList.Add(task);
}
//线程等待
Task.WaitAll(taskList.ToArray());
//测试输出结果
Console.WriteLine(this.TotalCount); //当不加线程锁的时候，结果不一定是10000，加锁后，一定为10000
}
5. 委托的几种赋值形式
三个方法：TestThread()、TestThread2(string name)、TestThread(string name,string pwd)。
形式一：声明的委托参数和要赋值的函数参数意义对应
eg： Action act1=TestThread ;
Action<string> act2=TestThread2;
Action<string,string> act3=TestThread3;
注意：这种形式，需要在委托被调用的时候将函数所需的参数值传递进去。
形式二： 声明无参数委托，但利用()=>进行将有参数的函数转换，可以直接将参数所需的值传递进去，委托调用的时候，将不需要再传递了。
eg： Action act1=TestThread ;
Action act2=()=>TestThread2("测试参数1");
Action act3=()=>TestThread3("测试参数1","测试参数2");
注意：这种形式，实际上就是直接将函数体赋值给委托，但又把一个函数当做内容传递到了这个函数体内，实际上
Action act2=()=>TestThread2("测试参数1"); 等价于
Action act2=()=>{
TestThread2("测试参数1");
}。
形式三： 直接将函数体赋值给委托，然后函数体中的内容为一个新的函数，这种形式，需要在委托被调用的时候将函数所需的参数值传递进去。
eg： Action act1=TestThread ;
Action act2=t=>TestThread2(t);
Action act3=(m,n)=>TestThread3(m,n);
注意：这种形式，实际上就是直接将函数体赋值给委托，但又把一个函数当做内容传递到了这个函数体内，实际上
Action act2=t=>TestThread2(t); 等价于
Action act2=(t)=>{
TestThread2("测试参数1");
}。