1.线程基础 -《多线程编程实战》
线程的生命周期,包括创建线程、挂起线程、线程等待,以及中止线程。
1.2 创建线程
class Program
{
static void Main(string[] args)
{
Thread t = new Thread(PrintNumbers);
t.Start();
PrintNumbers();
Console.Read();
}
static void PrintNumbers()
{
Console.WriteLine("开始...");
for (int i = 1; i < 50; i++)
{
Console.WriteLine(i);
}
}
}
1.2 创建线程
正在执行中的程序实例可被称为一个进程。进程由一个或多个线程组成。这意味着当运行程序时,始终有一个执行程序代码的是主线程。
结果两组范围为1到50的数字会随机交叉输出,说明 PrintNumbers 方法同时运行在主线程和另一个线程中。
1.3 暂停线程(Thread.Sleep)
本节展示让一个线程等待一段时间,而不用消耗操作系统资源。
static void Main(string[] args)
{
Thread t = new Thread(PrintNumbersWithDelay);
t.Start();
PrintNumbers();
Console.Read();
}
static void PrintNumbers()
{
Console.WriteLine("PrintNumbers开始...");
for (int i = 1; i < 10; i++)
{
Console.WriteLine(i);
}
}
static void PrintNumbersWithDelay()
{
Console.WriteLine("PrintNumbersWithDelay开始...");
for (int i = 1; i < 10; i++)
{
Thread.Sleep(TimeSpan.FromSeconds(2));
Console.WriteLine("多线程:" + i);
}
}
1.3 暂停线程
当程序运行时,会创建一个线程执行 PrintNumbersWithDelay 方法。然后立即执行 PrintNumbers 。PrintNumbersWithDelay 加入了
Thread.Sleep
(休眠)2秒。当线程休眠状态时,会尽可能少的 CPU 时间。结果发现 PrintNumbers 先执行完。
1.4 线程等待(Thread.Join)#
本节展示如何让程序等待另一个线程中的计算完成,然后在代码中使用该线程的计算结果。使用 Thread.Sleep 行不通,因为并不知道执行计算需要花费的具体时间。
static void Main(string[] args)
{
Console.WriteLine("主线程开始...");
Thread t = new Thread(PrintNumbersWithDelay);
t.Start();
t.Join();
Console.WriteLine("Thread completed");
Console.Read();
}
static void PrintNumbersWithDelay()
{
Console.WriteLine("PrintNumbersWithDelay开始...");
for (int i = 1; i < 10; i++)
{
Thread.Sleep(TimeSpan.FromSeconds(2));
Console.WriteLine("多线程:" + i);
}
}
1.4 线程等待(Thread.Join)
当程序启动一个耗时较长的线程来打印数字,打印每个数字前要等待2秒。但我们主程序调用了
t.Join
方法,该方法允许我们等待指导线程 t 完成。当线程完成时,主程序会继续运行。
借助该技术可以实现两个线程间的同步执行步骤。第一个线程会等待另一个线程完成后再继续执行。第一个线程等待时,是处于阻塞状态。
1.5 终止线程(Thread.Abort)#
static void Main(string[] args)
{
Console.WriteLine("开始程序..");
Thread t = new Thread(PrintNumbersWithDelay);
t.Start();
Thread.Sleep(TimeSpan.FromSeconds(6));
t.Abort();
Console.WriteLine("一个线程终止了~~");
t = new Thread(PrintNumbers);
t.Start();
PrintNumbers();
Console.Read();
}
static void PrintNumbersWithDelay()
{
Console.WriteLine("PrintNumbersWithDelay开始...");
for (int i = 1; i < 10; i++)
{
Thread.Sleep(TimeSpan.FromSeconds(2));
Console.WriteLine("多线程:" + i +",当前线程:"+ Thread.CurrentThread.ManagedThreadId);
}
}
static void PrintNumbers()
{
Console.WriteLine("PrintNumbers 开始...");
for (int i = 1; i < 10; i++)
{
Console.WriteLine(i + ",当前线程:" + Thread.CurrentThread.ManagedThreadId);
}
}
1.5 终止线程
当主程序和单独的数字打印线程运行时,等待6秒调用
t.Abort
方法。这给线程注入 ThreadAbortException 方法,导致线程被终止。使用该技术不一定能终止线程。目标线程可以通过处理该异常并调用
Thread.ResetAbort
方法来拒绝被终止。因此不推荐使用Abort
方法关闭线程。可以使用其他方法,比如提供一个CancellationToken
方法来取消线程执行。
1.6 检测线程状态(Thread.CurrentThread)#
public enum ThreadState
{
Running = 0, //线程已启动,它未被阻塞,并且没有挂起的
StopRequested = 1, //正在请求线程停止。 这仅用于内部
SuspendRequested = 2, //正在请求线程挂起
Background = 4, //线程正作为后台线程执行(相对于前台线程而言)通过设置Thread.IsBackground来控制
Unstarted = 8, //尚未对线程调用 Thread.Start() 方法
Stopped = 16, //线程已停止
WaitSleepJoin = 32, //线程已被阻止。Thread.Sleep 或 Thread.Join()、请求锁定或等待线程同步对象
Suspended = 64, //线程已挂起
AbortRequested = 128, //已对线程调用了 Thread.Abort 方法,但线程尚未收到试图终止它的挂起的
Aborted = 256, //程状态包括ThreadState.AbortRequested并且该线程现在已死,但其状态尚未更改为ThreadState.Stopped
}
下面看示例:
static void Main(string[] args)
{
Console.WriteLine("开始程序。。");
Thread t = new Thread(PrintNumbersWithStatus);
Thread t2 = new Thread(DoNothing);
Console.WriteLine("t的线程状态:" + t.ThreadState.ToString() + ",t线程:" + t.ManagedThreadId);
t2.Start();
t.Start();
for (int i = 1; i < 30; i++)
{
Console.WriteLine("t的线程状态:" + t.ThreadState.ToString() + ",t线程:" + t.ManagedThreadId);
}
Thread.Sleep(TimeSpan.FromSeconds(6));
t.Abort();
Console.WriteLine("一个线程终止了~~");
Console.WriteLine("t的线程状态:" + t.ThreadState.ToString() + ",t线程:" + t.ManagedThreadId);
Console.WriteLine("t2的线程状态:" + t2.ThreadState.ToString() + ",t2线程:" + t2.ManagedThreadId);
Console.Read();
}
static void DoNothing()
{
Console.WriteLine("DoNothing开始...");
Thread.Sleep(TimeSpan.FromSeconds(2));
}
static void PrintNumbersWithStatus()
{
Console.WriteLine("PrintNumbersWithStatus开始...");
Console.WriteLine("当前线程状态:" + Thread.CurrentThread.ThreadState.ToString() + ",当前线程:" + Thread.CurrentThread.ManagedThreadId);
for (int i = 1; i < 10; i++)
{
Thread.Sleep(TimeSpan.FromSeconds(2));
Console.WriteLine("多线程:" + i + ",当前线程:" + Thread.CurrentThread.ManagedThreadId);
}
}
1.6 检测线程状态
网友评论