zoukankan      html  css  js  c++  java
  • C#多线程学习之如何操纵一个线程

    下面我们就动手来创建一个线程,使用Thread类创建线程时,只需提供线程入口即可。(线程入口使程序知道该让这个线程干什么事)

    在C#中,线程入口是通过ThreadStart代理(delegate)来提供的,你可以把ThreadStart理解为一个函数指针,指向线程要执行的函数,当调用Thread.Start()方法后,线程就开始执行ThreadStart所代表或者说指向的函数。

    打开你的VS.net,新建一个控制台应用程序(Console Application),编写完全控制一个线程的代码示

    using System;
    using System.Threading; 
    
    namespace ThreadTest
    {
        public class Alpha
        {
            public void Beta()
            {
                while (true)
                {
                    Console.WriteLine("Alpha.Beta is running in its own thread.");
                }
            }
        }; 
    
    public class Simple
    {
        public static int Main()
        {
              Console.WriteLine("Thread Start/Stop/Join Sample");
                Alpha oAlpha = new Alpha();
            file://这里创建一个线程,使之执行Alpha类的Beta()方法
            Thread oThread = new Thread(new ThreadStart(oAlpha.Beta));
            oThread.Start();
            while (!oThread.IsAlive)
                  Thread.Sleep(1);
                  oThread.Abort();
                  oThread.Join();
                  Console.WriteLine();
                  Console.WriteLine("Alpha.Beta has finished"); 
                  try 
                  {
                    Console.WriteLine("Try to restart the Alpha.Beta thread");
                    oThread.Start();
                  }
                  catch (ThreadStateException) 
                  {
                   Console.Write("ThreadStateException trying to restart Alpha.Beta. ");
                   Console.WriteLine("Expected since aborted threads cannot be restarted.");
                   Console.ReadLine();
                  }
                return 0;
        }
        }
    }

    这段程序包含两个类Alpha和Simple,在创建线程oThread时我们用指向Alpha.Beta()方法的初始化了ThreadStart代理(delegate)对象,当我们创建的线程oThread调用oThread.Start()方法启动时,实际上程序运行的是Alpha.Beta()方法:

    Alpha oAlpha = new Alpha();

    Thread oThread = new Thread(new ThreadStart(oAlpha.Beta));

    oThread.Start();

    然后在Main()函数的while循环中,我们使用静态方法Thread.Sleep()让主线程停了1ms,这段时间CPU转向执行线程oThread。然后我们试图用Thread.Abort()方法终止线程oThread,注意后面的oThread.Join(),Thread.Join()方法使主线程等待,直到oThread线程结束。你可以给Thread.Join()方法指定一个int型的参数作为等待的最长时间。之后,我们试图用Thread.Start()方法重新启动线程oThread,但是显然Abort()方法带来的后果是不可恢复的终止线程,所以最后程序会抛出ThreadStateException异常。


  • 相关阅读:
    javaWeb 使用 filter 处理 html 标签问题
    javaWeb 使用 filter 处理全站乱码问题
    Kubernetes常见部署方案--滚动更新、重新创建、蓝绿、金丝雀
    阿里云
    Kubernetes技术分析之灰度升级
    fetch进行post请求为什么会首先发一个options 请求?
    免费给你的网站加速,全球访问速度杠杠的
    抗DDOS,我选Cloudflare,免费!
    被骗几十万总结出来的Ddos攻击防护经验!------转自 服务器之家server
    微服务部署:蓝绿部署、滚动部署、灰度发布、金丝雀发布
  • 原文地址:https://www.cnblogs.com/haxianhe/p/9271272.html
Copyright © 2011-2022 走看看