C#通过接口与线程通信(捕获线程状态)示例代码

C#通过接口与线程通信(捕获线程状态)示例的完整攻略如下：

线程状态概述

在进行线程通信之前，先要理解线程的状态。在 C# 中，线程有以下几种状态：

• Unstarted: 表示线程已被创建，但未开始执行。
• Running: 表示线程正在运行。
• Stopped: 表示线程已经停止。
• WaitSleepJoin: 表示线程正在等待被调用，或正在进行 Wait、Sleep、Join 操作。
• Suspended: 表示线程已被挂起，暂停执行。

捕获线程状态

为了捕获线程的状态，我们可以使用 ThreadState 枚举。该枚举定义了与线程状态相关的常量，可以通过二进制运算符将不同的状态组合起来。

以下是 ThreadState 常用的几个常量（使用 | 运算符组合）：

• ThreadState.Running | ThreadState.WaitSleepJoin: 表示线程正在运行或等待调用。
• ThreadState.Stopped | ThreadState.Unstarted: 表示线程已经停止或未开始运行。
• ThreadState.Suspended: 表示线程已被挂起。

通过接口与线程通信示例

下面我们来看两个简单的示例，演示如何通过接口与线程通信并捕获线程状态。

示例一：启动线程并捕获状态

首先，我们需要定义一个接口 IThreadStatus，包含了一个方法 OnThreadStatusChanged。该方法用于接收线程状态的变化信息。

public interface IThreadStatus
{
    void OnThreadStatusChanged(string threadName, ThreadState state);
}

接下来，我们就可以创建一个带有状态捕获功能的线程了。该线程通过 IThreadStatus 接口与外界通信。

public class StatusThread
{
    private Thread thread;
    private IThreadStatus listener;

    public StatusThread(IThreadStatus listener)
    {
        this.listener = listener;
        thread = new Thread(Run);
    }

    public void Start()
    {
        thread.Start();
        listener.OnThreadStatusChanged(thread.Name, GetThreadState());
    }

    public void Stop()
    {
        thread.Abort();
        listener.OnThreadStatusChanged(thread.Name, GetThreadState());
    }

    public ThreadState GetThreadState()
    {
        return thread.ThreadState;
    }

    private void Run()
    {
        // 线程执行的代码
    }
}

在 StatusThread 的构造函数中，我们将传入的 IThreadStatus 实例保存到私有成员 listener 中，以便后续与之通信。

在 Start 方法中，我们启动了新线程，并通过 listener.OnThreadStatusChanged 方法，将线程状态传递出去。在 Stop 方法中同样如此。

注意，我们使用了 thread.Name 来表示线程名。在创建线程时，可以给线程对象设置名称：

var thread = new Thread(Run);
thread.Name = "MyThread";

这样，在调用 OnThreadStatusChanged 方法时，就可以获得该线程的名称了。

接下来，我们需要实现 IThreadStatus 接口。例如：

public class MyThreadStatusChangeListener : IThreadStatus
{
    public void OnThreadStatusChanged(string threadName, ThreadState state)
    {
        Console.WriteLine($"线程 {threadName} 的状态发生了变化，当前状态为 {state}。");
    }
}

在这个实现中，我们只是简单地将线程的状态信息输出到控制台。当然，你可以根据实际需求对状态变化进行响应。

最后，我们就可以创建一个 StatusThread 对象，并启动它了：

var statusThread = new StatusThread(new MyThreadStatusChangeListener());
statusThread.Start();

示例二：通过按钮控制线程状态

以上示例我们演示了如何在启动和停止线程时，通过接口与外部通信并捕获线程状态。接下来，我们来看看如何通过按钮控制线程的启动和停止。

首先，我们需要在窗口中添加两个按钮 btnStart 和 btnStop，并分别给它们添加点击事件处理方法：

private StatusThread statusThread;

// 点击“启动”按钮
private void btnStart_Click(object sender, EventArgs e)
{
    if (statusThread != null)
    {
        statusThread.Start();
    }
}

// 点击“停止”按钮
private void btnStop_Click(object sender, EventArgs e)
{
    if (statusThread != null)
    {
        statusThread.Stop();
    }
}

在 btnStart_Click 和 btnStop_Click 方法中，我们直接调用 StatusThread 中的 Start 和 Stop 方法即可。

接下来，我们需要从窗口中创建一个 MyThreadStatusChangeListener 实例，并将它传递给 StatusThread 对象：

private void Form1_Load(object sender, EventArgs e)
{
    var listener = new MyThreadStatusChangeListener();
    statusThread = new StatusThread(listener);
}

在窗口加载完成后，我们创建了一个 MyThreadStatusChangeListener 实例，并将其作为参数，传递给了 StatusThread 的实例。这样，我们就可以在窗口中来控制该线程的启动和停止了。

完整代码请参考以下示例：

using System;
using System.Threading;

namespace ThreadStatusDemo
{
    public partial class Form1 : Form, IThreadStatus
    {
        private StatusThread statusThread;

        // 窗口初始化方法
        public Form1()
        {
            InitializeComponent();
        }

        // 加载窗口时进行初始化
        private void Form1_Load(object sender, EventArgs e)
        {
            var listener = new MyThreadStatusChangeListener();
            statusThread = new StatusThread(listener);
        }

        // 点击“启动”按钮
        private void btnStart_Click(object sender, EventArgs e)
        {
            if (statusThread != null)
            {
                statusThread.Start();
            }
        }

        // 点击“停止”按钮
        private void btnStop_Click(object sender, EventArgs e)
        {
            if (statusThread != null)
            {
                statusThread.Stop();
            }
        }

        // 捕获线程状态变化的方法
        public void OnThreadStatusChanged(string threadName, ThreadState state)
        {
            Console.WriteLine($"线程 {threadName} 的状态发生了变化，当前状态为 {state}。");
        }
    }

    // 实现 IThreadStatus 接口的监听器
    public class MyThreadStatusChangeListener : IThreadStatus
    {
        public void OnThreadStatusChanged(string threadName, ThreadState state)
        {
            Console.WriteLine($"线程 {threadName} 的状态发生了变化，当前状态为 {state}。");
        }
    }

    // 带有状态捕获功能的线程
    public class StatusThread
    {
        private Thread thread;
        private IThreadStatus listener;

        public StatusThread(IThreadStatus listener)
        {
            this.listener = listener;
            thread = new Thread(Run);
        }

        public void Start()
        {
            thread.Start();
            listener.OnThreadStatusChanged(thread.Name, GetThreadState());
        }

        public void Stop()
        {
            thread.Abort();
            listener.OnThreadStatusChanged(thread.Name, GetThreadState());
        }

        public ThreadState GetThreadState()
        {
            return thread.ThreadState;
        }

        private void Run()
        {
            // 线程执行的代码
        }
    }

    // 表示捕获线程状态变化的接口
    public interface IThreadStatus
    {
        void OnThreadStatusChanged(string threadName, ThreadState state);
    }
}