C#多线程精解:优雅终止线程的实用方法与技巧

 

概述:在C#多线程编程中,合理终止线程是关键挑战。通过标志位或CancellationToken,实现安全、协作式的线程终止,确保在适当时机终止线程而避免资源泄漏。

应用场景:

在C#多线程编程中,有时需要终止正在运行的线程,例如在用户取消操作、程序关闭等情况下。

思路:

线程终止通常涉及到合作式终止而非强制终止,因为强制终止可能导致资源泄漏和不确定的状态。一般采用标志位、信号等方式,让线程自行安全地退出。

方法和步骤:

1.使用标志位控制线程执行:

using System;
using System.Threading;
public class Worker
{
// 标志位,用于控制线程执行
private volatile bool shouldStop = false;
public void DoWork()
{
while (!shouldStop)
{
// 线程执行的工作
Console.WriteLine("Working...");
Thread.Sleep(1000); // 模拟工作
}
}
// 设置标志位,终止线程
public void StopWork()
{
shouldStop = true;
}
}
public class Program
{
public static void Main()
{
Worker worker = new Worker();
// 启动线程执行工作
Thread thread = new Thread(worker.DoWork);
thread.Start();
// 模拟运行一段时间后,终止线程
Thread.Sleep(5000);
worker.StopWork();
// 等待线程结束
thread.Join();
Console.WriteLine("Thread stopped.");
}
}
using System;
using System.Threading;

public class Worker
{
    // 标志位,用于控制线程执行
    private volatile bool shouldStop = false;

    public void DoWork()
    {
        while (!shouldStop)
        {
            // 线程执行的工作
            Console.WriteLine("Working...");
            Thread.Sleep(1000); // 模拟工作
        }
    }

    // 设置标志位,终止线程
    public void StopWork()
    {
        shouldStop = true;
    }
}

public class Program
{
    public static void Main()
    {
        Worker worker = new Worker();

        // 启动线程执行工作
        Thread thread = new Thread(worker.DoWork);
        thread.Start();

        // 模拟运行一段时间后,终止线程
        Thread.Sleep(5000);
        worker.StopWork();

        // 等待线程结束
        thread.Join();

        Console.WriteLine("Thread stopped.");
    }
}
using System; using System.Threading; public class Worker { // 标志位,用于控制线程执行 private volatile bool shouldStop = false; public void DoWork() { while (!shouldStop) { // 线程执行的工作 Console.WriteLine("Working..."); Thread.Sleep(1000); // 模拟工作 } } // 设置标志位,终止线程 public void StopWork() { shouldStop = true; } } public class Program { public static void Main() { Worker worker = new Worker(); // 启动线程执行工作 Thread thread = new Thread(worker.DoWork); thread.Start(); // 模拟运行一段时间后,终止线程 Thread.Sleep(5000); worker.StopWork(); // 等待线程结束 thread.Join(); Console.WriteLine("Thread stopped."); } }

上述代码中,通过设置shouldStop标志位,线程在下一个循环中检查到标志位为true时自动退出。

2.使用CancellationToken终止线程:

using System;
using System.Threading;
public class Worker
{
// CancellationTokenSource用于生成CancellationToken
private CancellationTokenSource cts = new CancellationTokenSource();
public void DoWork()
{
CancellationToken token = cts.Token;
while (!token.IsCancellationRequested)
{
// 线程执行的工作
Console.WriteLine("Working...");
Thread.Sleep(1000); // 模拟工作
}
}
// 使用CancellationToken请求终止线程
public void StopWork()
{
cts.Cancel();
}
}
public class Program
{
public static void Main()
{
Worker worker = new Worker();
// 启动线程执行工作
Thread thread = new Thread(worker.DoWork);
thread.Start();
// 模拟运行一段时间后,终止线程
Thread.Sleep(5000);
worker.StopWork();
// 等待线程结束
thread.Join();
Console.WriteLine("Thread stopped.");
}
}
using System;
using System.Threading;

public class Worker
{
    // CancellationTokenSource用于生成CancellationToken
    private CancellationTokenSource cts = new CancellationTokenSource();

    public void DoWork()
    {
        CancellationToken token = cts.Token;

        while (!token.IsCancellationRequested)
        {
            // 线程执行的工作
            Console.WriteLine("Working...");
            Thread.Sleep(1000); // 模拟工作
        }
    }

    // 使用CancellationToken请求终止线程
    public void StopWork()
    {
        cts.Cancel();
    }
}

public class Program
{
    public static void Main()
    {
        Worker worker = new Worker();

        // 启动线程执行工作
        Thread thread = new Thread(worker.DoWork);
        thread.Start();

        // 模拟运行一段时间后,终止线程
        Thread.Sleep(5000);
        worker.StopWork();

        // 等待线程结束
        thread.Join();

        Console.WriteLine("Thread stopped.");
    }
}
using System; using System.Threading; public class Worker { // CancellationTokenSource用于生成CancellationToken private CancellationTokenSource cts = new CancellationTokenSource(); public void DoWork() { CancellationToken token = cts.Token; while (!token.IsCancellationRequested) { // 线程执行的工作 Console.WriteLine("Working..."); Thread.Sleep(1000); // 模拟工作 } } // 使用CancellationToken请求终止线程 public void StopWork() { cts.Cancel(); } } public class Program { public static void Main() { Worker worker = new Worker(); // 启动线程执行工作 Thread thread = new Thread(worker.DoWork); thread.Start(); // 模拟运行一段时间后,终止线程 Thread.Sleep(5000); worker.StopWork(); // 等待线程结束 thread.Join(); Console.WriteLine("Thread stopped."); } }

上述代码中,通过CancellationToken及其关联的CancellationTokenSource,在StopWork方法中调用Cancel方法通知线程终止。

在实际应用中,需要根据具体场景选择合适的终止线程的方式,并确保线程能够在终止时完成清理工作。

 

© 版权声明
THE END
支持一下吧
点赞12 分享
评论 抢沙发
头像
请文明发言!
提交
头像

昵称

取消
昵称表情代码快捷回复

    暂无评论内容