首先需要先实例化一个信号对象 ManualResetEvent signal= new ManualResetEvent(false);
signal.WaitOne() 阻塞当前线程,等待接收到其他线程发来的取消信号
signal.Set() 发送取消阻塞信号, 取消成功返回true,失败返回false
signal.Reset() 发送再次阻塞信号,阻塞成功返回true,失败返回false
public partial class Form2 : Form { // 线程间信号,在一个线程中调用WaitOne方法阻塞等待,直到收到信号 // 另一个线程中使用Set方法发送信号 ManualResetEvent signal; public Form2() { InitializeComponent(); signal = new ManualResetEvent(false); new Thread(Test1).Start(); new Thread(Test2).Start(); } public void Test1() { while (true) { signal.WaitOne();// 阻塞当前线程,直到等到信号 Console.WriteLine("收到信号"); Thread.Sleep(100); } } public void Test2() { int i = 0; while(i< 3) { i++; Console.WriteLine(i); Thread.Sleep(1000); } Console.WriteLine("等待结束"); signal.Set(); // 取消阻塞 signal.Reset(); // 再次阻塞 } }
/* * 场景:当主线程开辟了一个子线程去执行一个耗时的操作,执行了一段时间还没结束,这时主线程等不及了,于是就发出申请 * 取消子线程继续执行,就是告诉子线程你可以结束了。 */ public partial class CancellationTokenForm : Form { // 创建token CancellationTokenSource cts = new CancellationTokenSource(); public CancellationTokenForm() { InitializeComponent(); Task.Run(Test); } void Test() { while (true) { // 外部发出取消继续执行当前线程的请求 if (cts.IsCancellationRequested) { break; } Console.WriteLine("等待中..."); Thread.Sleep(500); } Console.WriteLine("等待结束"); } private void button1_Click(object sender, EventArgs e) { // 发出取消继续执行线程的申请 cts.Cancel(); } }