asp.net中C# Thread的简单例子

作者:袖梨 2022-06-25

Thread类可以创建和控制线程,Thread类的构造函数重载为接受ThreadStart和ParameterizedThreadStart类型的委托参数。下面我们用一个例子来解释怎样用Thread类来创建一个简单的线程

 代码如下 复制代码


       static void Main(string[] args)
        {
            #region Thread无参数举例
            Thread th = new Thread(ThreadChild);
            th.Start();
            Console.WriteLine("Main Thread Start!");
            #endregion
        }
        static void ThreadChild()
        {
            Console.WriteLine("Child Thread Start!");
        }

 

程序运行的结果不能保证哪个先输出,因为线程是由操作系统调度,每次哪个线程在前面可以不同

 

给线程传递数据

    上面的例子演示了怎样用Thread类来创建一个不带传参的线程,下面我门来创建一个带传入参数的线程。给线程传递参数,有两种方式,一种是使用带ParameterizedThreadStart委托参数的Thread的构造函数,另外一种是定义一个自定义类。首先我们使用ParameterizedThreadStart委托来创建有传入参数的类。使用ParameterizedThreadStart,线程的入口(线程调用的方法)必须有一个Object类型的参数,使用Object我们首先想到的就是类型不安全。而且在执行线程的时候多半有装箱拆箱操作。管它的,我们先用这种方式来创建一个带传入参数的线程!!

  废话再多,还是没有直接上代码来得实在,看代码!!

 代码如下 复制代码


        static void Main(string[] args)
        {    
            #region 使用parameterizedThreadStart委托执行带参数的委托
            Thread th2 = new Thread(Thread_param);
            th2.Start(20);
            #endregion        
        }
        static void Thread_param(object msg)
        {
            int message = (int)msg;
            Console.WriteLine("Result:{0}",message);
        }

 

 

上面创建的线程是类型不安全的,那用什么样的方式执行带传入参数的线程的方法是类型安全的呢,答案就是创建一个自定义类,在类中定义一个作为传入参数的字段,将线程的主方法定义为一个类的实例方法。然而使用这种方法就可以使用泛型来解决使用ParameterizedThreadStart的类型不安全

看招!!!!

 代码如下 复制代码


class Program
    {
        static void Main(string[] args)
        {
            #region 使用自定义类实现带参数的线程
            MyThread mythread = new MyThread("Thread_child");
            Thread th3 = new Thread(mythread.ThreadChild);
            th3.Start();
            #endregion
        }
    }
    class MyThread
    {
        private T data;
        public MyThread(T data)
        {
            this.data = data;
        }
        public void ThreadChild()
        {
            Console.WriteLine("Child Thread Start! Result:{0}",data);
        }
}

 

 

后台线程  

  Thread类默认创建的是前台线程,所以我们前面创建的线程全部都是前台线程。只要有一个前台线程在运行,应用程序的进程就在运行。如果有多个前台线程在运行,而Main()方法(主线程)结束了,应用程序的进程就仍然是激活的,直到所有前台线程完成其任务为止。

  那后台线程呢?显然和前台线程相反。当主线程结束后,应用程序的进程就终止了,在所有前台线程结束后,后台线程就会被终止。

  在编码的时候我们可以设置Thread类的IsBackground的属性来确定该线程是前台线程还是后台线程。当IsBackground设置为False的时候,为前台线程,设置为Ture的时候为后台线程,下面我们举例来说明前台线程和后台线程的区别。首先我们创建一个前台线程。

 代码如下 复制代码


        static void Main(string[] args)
        {
            Thread th_pre = new Thread(Thread_pre)
            {Name="Thread_pre",IsBackground=flase};;
            th_pre.Start();
            Console.WriteLine("主线程执行完成!");
        }
        static void Thread_pre()
        {
            Console.WriteLine("子线程开始执行!");
            Thread.Sleep(3000);
            Console.WriteLine("子线程执行完成!");
        }

从上面的运行结果可以看到,当主线程执行完成后,应用程序终止前就会子线程执行完成。 

下面我们来看看后台线程,看代码!!

 代码如下 复制代码


     static void Main(string[] args)
        {
       Thread th_back = new Thread(Thread_back)
       { Name="Thread_back",IsBackground=true };
            th_back.Start();
            Console.WriteLine("主线程执行完成!");
        }
        static void Thread_back()
        {
            Console.WriteLine("子线程开始执行!");
            Thread.Sleep(3000);
            Console.WriteLine("子线程执行完成!");
        }

 

  从运行结果可以看出,当主线程结束后,进程就终止了,后台线程也被终止,所以没有后台线程结束的输出信息。

 控制线程

  我们使用Thread创建线程后,我们需要对线程进行控制。

  1、  使用Start()方法使线程处于Running状态,线程开始执行。

  2、  使用Join()方法使线程处于WaitSleepJoin状态,在继续执行标准的 COM 和 SendMessage 消息泵处理期间,阻塞调用线程,直到某个线程终止或经过了指定时   间为止。

  3、  使用Sleep()方法,也会使线程处于WaitSleepJoin状态,在经历Sleep()方法定义的时间段后,线程就会被再次唤醒。、

  4、  使用Abort()方法,会使线程处于ResetAbort()状态,线程在接到这个命令的时候,会抛出一个ThradAbordException类型的异常。

各位看官,看代码

 代码如下 复制代码


using System;
using System.Text;
using System.Threading;
namespace ConsoleThreadContral
{
    class Program
    {
        static void Main(string[] args)
        {
            Console.WriteLine("mainThread Start!");
            Thread th = new Thread(newThread);
            th.Start();//将当前实例的状态更改为 ThreadState.Running。
            Console.WriteLine("newThread State:{0}",th.ThreadState);
            th.Join(100);//在继续执行标准的 COM 和 SendMessage 消息泵处理期间,阻塞调用线程,直到某个线程终止或经过了指定时间为止。
            Console.WriteLine("newThread State:{0}", th.ThreadState);
            th.Abort();//在调用此方法的线程上引发 ThreadAbortException,以开始终止此线程的过程。 调用此方法通常会终止线程。
            Console.WriteLine("newThread State:{0}", th.ThreadState);
        }
        static void newThread()
        {
            Console.WriteLine("newThread Start!");
            Thread.Sleep(10000);
            Console.WriteLine("newThread Complete!");
        }
    }
}

本文以一个简单的例子说明如何创建一个线程、一个带有参数的线程。需要说明的是,ThreadStart、ParameterizedThreadStart这两个函数的参数是一个函数名,是通过委托实现的,前者创建一个无参的线程、后者创建一个带有参数的线程。

 代码如下 复制代码

 using System;
    using System.Collections;
    using System.Text;
    using System.Threading;
    
    namespace thread {
    class thread {
    public static void print1() {
    for (int i = 1; i < 20; i++) {
    Console.WriteLine(" Thread name: {0}, number = {1}",Thread.CurrentThread.Name,i);
    Thread.Sleep(200);
    }
    }
    public static void print2() {
    for (int i = 220; i < 245; i++) {
    Console.WriteLine(" Thread name: {0}, number = {1}", Thread.CurrentThread.Name, i);
    Thread.Sleep(200);
    }
    }
    public static void print3() {
    for (int i = 530; i < 552; i++) {
    Console.WriteLine(" Thread name: {0}, number = {1}", Thread.CurrentThread.Name, i);
    Thread.Sleep(200);
    }
    }
    public static void print(object obj) {
    // int star = ((para)obj).getA(),end = ((para)obj).getB();
    int star = (int)(((ArrayList)obj)[0]), end = (int)(((ArrayList)obj)[1]);
    for (int i = star; i < end; i++) {
    Console.WriteLine(" Thread name: {0}, number = {1}", Thread.CurrentThread.Name, i);
    Thread.Sleep(200);
    }
    }
    class para {
    private int a;
    private int b;
    
    public void add(int a, int b) {
    this.a = a;
    this.b = b;
    }
    public int getA() {
    return this.a;
    }
    public int getB() {
    return this.b;
    }
    }
    static void Main(string[] args) {
    Console.WriteLine(" Main thread start. ");
    /******
    Thread t1 = new Thread(new ThreadStart(print1));
    t1.Name = "thread1";
    Thread t2 = new Thread(new ThreadStart(print2));
    t2.Name = "thread2";
    Thread t3 = new Thread(new ThreadStart(print3));
    t3.Name = "thread3"; t1.Start();
    t2.Start(); t3.Start();
    t1.Join();
    t2.Join();
    t3.Join();
    *******/
    Thread t = new Thread(new ParameterizedThreadStart(thread.print));
    // para p = new para();
    // p.add(1,20);
    ArrayList list = new ArrayList();
    list.Add(1);
    list.Add(20);
    t.Name = "thread1";
    t.Start(list);
    Thread tt = new Thread(new ParameterizedThreadStart(thread.print));
    // para p = new para();
    // p.add(1,20);
    list[0] = 220;
    list[1] = 245;
    tt.Name = "thread2";
    tt.Start(list);
    Thread ttt = new Thread(new ParameterizedThreadStart(thread.print));
    // para p = new para();
    // p.add(1,20);
    list[0] = 530;
    list[1] = 552;
    ttt.Name = "thread3";
    ttt.Start(list);
    t.Join();
    Console.WriteLine(" Main thread finish.");
    Console.ReadLine();
    }
    }
    }

C# Thread类:判断多个线程是否都结束

线程也可以采用计数器的方法,即为所有需要监视的线程设一个线程计数器,每开始一个线程,在线程的执行方法中为这个计数器加1,如果某个线程结束(在线程执行方法的最后为这个计数器减1),为这个计数器减1。然后再开始一个线程,按着一定的时间间隔来监视这个计数器,如是棕个计数器为0,说明所有的线程都结束了。当然,也可以不用这个监视线程,而在每一个工作线程的最后(在为计数器减1的代码的后面)来监视这个计数器,也就是说,每一个工作线程在退出之前,还要负责检测这个计数器。使用这种方法不要忘了同步这个计数器变量啊,否则会产生意想不到的后果。

相关文章

精彩推荐