美文网首页
1.线程基础 -《多线程编程实战》

1.线程基础 -《多线程编程实战》

作者: 大捕猎店 | 来源:发表于2017-07-04 10:32 被阅读0次

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 检测线程状态

相关文章

网友评论

      本文标题:1.线程基础 -《多线程编程实战》

      本文链接:https://www.haomeiwen.com/subject/rtvthxtx.html