如何在重启线程前终止线程？C#线程重复启动崩溃问题解决

首先，咱们先拆解你的问题核心：你遇到的崩溃是因为Thread对象一旦执行完毕（进入终止状态）就无法再次启动，而你的代码可能在重复调用someFunction()时，尝试启动之前已经完成的旧线程实例。另外Thread.Abort()本身是不推荐的API（它会强制终止线程，容易引发资源泄漏或数据不一致），而且如果线程已经结束，调用它自然也不会有效果。

下面是具体的修改方案，一步步来：

1. 修复线程列表的复用问题 #

你的代码里存在变量名不一致的问题（比如listThreads和listaFredow混用），这会导致逻辑混乱，先统一变量名。另外，如果someFunction()会被多次调用，每次调用前必须清空线程列表，确保每次添加的都是全新的Thread实例：

public void someFunction()
{
    // 第一步：清空旧的线程列表，彻底抛弃已完成的线程实例
    listThreads.Clear();

    // 后续的Truck创建、线程添加逻辑...
}

这样每次调用someFunction()时，都是从头创建新的线程，不会碰到“启动已执行线程”的问题。

2. 用协作式取消替代Thread.Abort() #

Thread.Abort()是非常危险的操作，它会在任意时刻中断线程，可能导致线程持有的资源（比如文件锁、数据库连接）无法正确释放。正确的做法是让线程主动检查退出信号，自行终止：

第一步：给你的Truck类添加取消支持 #

以WaterTruck为例，修改它的构造函数和Drive方法，加入取消令牌：

public class WaterTruck
{
    private readonly CancellationToken _cancelToken;
    // 你的其他字段...

    public WaterTruck(/* 你的原有参数 */, CancellationToken cancelToken)
    {
        _cancelToken = cancelToken;
        // 其他初始化逻辑...
    }

    public void Drive()
    {
        // 线程的主循环里，定期检查取消信号
        while (!_cancelToken.IsCancellationRequested)
        {
            // 你的业务逻辑代码
            // 比如模拟运输过程的循环或任务

            // 每次循环都检查是否需要退出
            if (_cancelToken.IsCancellationRequested)
            {
                break;
            }

            // 可选：添加短暂延迟，避免空转占用CPU
            Thread.Sleep(100);
        }

        // 这里可以添加线程退出前的资源清理逻辑
        Console.WriteLine("WaterTruck 线程已安全退出");
    }
}

BarleyTruck和HopTruck也做同样的修改，把CancellationToken传入它们的Run方法中。

第二步：在SuperVisor中管理取消令牌 #

在SuperVisor类里添加一个CancellationTokenSource，用来生成取消信号，并且在需要终止线程时触发取消：

public class SuperVisor : Interface
{
    private List<WaterTruck> listTW;
    private List<BarleyTruck> listTB;
    public List<HopTruck> listTH;
    public List<Thread> listThreads;
    private CancellationTokenSource _cts; // 用于控制线程取消

    public SuperVisor(List<HopTruck> listath, List<WaterTruck> listatw, List<BarleyTruck> listatb, List<Thread> listafred)
    {
        this.listTH = listath;
        this.listTB = listatb;
        this.listThreads = listafred;
        this.listTW = listatw;
        _cts = new CancellationTokenSource();
    }

    public void someFunction()
    {
        listThreads.Clear();
        // 重置取消令牌源，确保每次调用都有新的信号
        _cts.Dispose();
        _cts = new CancellationTokenSource();

        // 创建WaterTruck时传入取消令牌
        listTW.Clear();
        for(int i = 1; i<=iletrzebaWody;i++) {
            listTW.Add(new WaterTruck(warzelnia, 10, _cts.Token));
        }
        foreach(WaterTruck elem in listTW) {
            listThreads.Add(new Thread(elem.Drive));
        }

        // BarleyTruck和HopTruck的创建逻辑同理，都传入_cts.Token
        // ...（省略重复代码）

        // 启动所有线程
        foreach (var thread in listThreads) {
            thread.Start();
        }
    }

    // 新增方法：安全终止所有线程
    public void StopAllThreads()
    {
        // 发送取消信号
        _cts.Cancel();
        // 等待所有线程主动退出
        foreach(var thread in listThreads)
        {
            if(thread.IsAlive)
            {
                thread.Join();
            }
        }
        Console.WriteLine("所有线程已安全终止");
    }
}

3. 额外的注意事项 #

• 如果你的someFunction()只会被调用一次，那清空线程列表的步骤可以省略，但统一变量名依然很重要。
• 如果你使用的是.NET Core或.NET 5+，更推荐使用Task而非Thread来管理异步任务，Task结合CancellationToken的生命周期管理会更简洁，而且支持更多现代异步特性。
• 确保在程序退出前调用StopAllThreads()，避免线程在后台残留。

内容的提问来源于stack exchange，提问作者itsMe