C#中ManualResetEvent實(shí)現(xiàn)線程的暫停與恢復(fù)
更新時間：2022年01月20日 11:35:29 作者：chester·chen
本文主要介紹了C#中ManualResetEvent實(shí)現(xiàn)線程的暫停與恢復(fù)，文中通過示例代碼介紹的非常詳細(xì)，具有一定的參考價值，感興趣的小伙伴們可以參考一下
背景
前些天遇到一個需求，在沒有第三方源碼的情況下，刷新一個第三方UI，并且攔截到其ajax請求的返回結(jié)果。當(dāng)結(jié)果為AVALIABLE的時候，停止刷新并語音提示，否則繼續(xù)刷新。
分析這個需求，發(fā)現(xiàn)需要控制一個刷新循環(huán)的暫停與開始，因此網(wǎng)上搜到了通過ManualResetEvent實(shí)現(xiàn)線程的暫停與恢復(fù)。
ManualResetEvent介紹
ManualResetEvent是一個通過信號機(jī)制，實(shí)現(xiàn)線程間狀態(tài)同步的類。常用的方法有以下三個：
- WaitOne：阻止當(dāng)前線程，直到收到信號
- Reset：將事件狀態(tài)設(shè)置為非終止?fàn)顟B(tài)，導(dǎo)致線程阻止
- Set：將事件狀態(tài)設(shè)置為終止?fàn)顟B(tài)，從而允許繼續(xù)執(zhí)行一個或多個等待線程
實(shí)現(xiàn)設(shè)計(jì)
1.通過CefSharp的谷歌瀏覽器插件請求第三方網(wǎng)站
2.具體交互邏輯如下
默認(rèn)開啟一個線程，并通過WaitOne掛起，等待手動開始自動刷新的指令
手動通過Set方法發(fā)送開始工作信號
執(zhí)行完面操作后，通過Reset將線程再次掛起，并等待Ajax結(jié)果，判斷Ajax結(jié)果，如果不等于AVALIABLE則再次恢復(fù)線程
? ? ? ? public Form1()
? ? ? ? {
? ? ? ? ? ? InitializeComponent();
? ? ? ? ? ? var setting = new CefSettings();
? ? ? ? ? ? setting.Locale = "zh-CN";
? ? ? ? ? ? setting.UserAgent = "Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/50.0.2661.102 Safari/537.36";
? ? ? ? ? ? // 避免頁面加載不出來, 建議加上這句
? ? ? ? ? ? Cef.Initialize(setting);
? ? ? ? ? ? workerThread = new Thread(new ThreadStart(BeginListenWorkerAsync));
? ? ? ? ? ? workerThread.IsBackground = true;
? ? ? ? ? ? workerThread.Start();
? ? ? ? ? ? this.停止自動監(jiān)聽ToolStripMenuItem.Enabled = false;
? ? ? ? }
? ? ? ? private async void BeginListenWorkerAsync()
? ? ? ? {
? ? ? ? ? ? while (true)
? ? ? ? ? ? {
? ? ? ? ? ? ? ? _eventBeginListenWorkList.WaitOne(); ?//1.默認(rèn)掛起線程，等待信號
? ? ? ? ? ? ? ? chromiumWebBrowser1.GetBrowser().MainFrame.ExecuteJavaScriptAsync(@"document.evaluate(""http://*[@id='root']/div[1]/div[2]/div/div[2]/div[1]/div[1]/div/div[1]/button"", document).iterateNext().click()");
? ? ? ? ? ? ? ? Thread.Sleep(1000);
? ? ? ? ? ? ? ? chromiumWebBrowser1.GetBrowser().MainFrame.ExecuteJavaScriptAsync(@"document.evaluate(""http://*[@id='root']/div[1]/div[2]/div/div[1]/div/div/div/div[2]/div[6]/div/button"", document).iterateNext().click()");
? ? ? ? ? ? ? ? _eventBeginListenWorkList.Reset(); //3.頁面執(zhí)行完相應(yīng)操作則再次掛起線程，等待ajax請求結(jié)果再判斷是否恢復(fù)線程
? ? ? ? ? ? }
? ? ? ? }
? ? ? ? private void 停止自動監(jiān)聽ToolStripMenuItem_Click(object sender, EventArgs e)
? ? ? ? {
? ? ? ? ? ? this.開始自動監(jiān)聽ToolStripMenuItem.Enabled = true;
? ? ? ? ? ? this.停止自動監(jiān)聽ToolStripMenuItem.Enabled = false;
? ? ? ? ? ? _eventBeginListenWorkList.Reset();
? ? ? ? ? ? StartListen = false;
? ? ? ? }
? ? ? ? private void 開始自動監(jiān)聽ToolStripMenuItem_Click(object sender, EventArgs e)
? ? ? ? {
? ? ? ? ? ? this.開始自動監(jiān)聽ToolStripMenuItem.Enabled = false;
? ? ? ? ? ? this.停止自動監(jiān)聽ToolStripMenuItem.Enabled = true;
? ? ? ? ? ? _eventBeginListenWorkList.Set(); // 2.手動通過Set發(fā)送信號恢復(fù)線程，讓其工作
? ? ? ? ? ? StartListen = true;
? ? ? ? }3.現(xiàn)在我們需要定義RequestHandler來指定ResourceHandler攔截ajax請求
? ? ? ? private void Form1_Load(object sender, EventArgs e)
? ? ? ? {
? ? ? ? ? ? chromiumWebBrowser1.RequestHandler = new MyRequestHandler(this);
? ? ? ? ? ? chromiumWebBrowser1.Load("https://www.xxxxxxxx.com/");
? ? ? ? }MyRequestHandler中需要指定自定義ResourceHandler
? ? public class MyRequestHandler : RequestHandler
? ? {
? ? ? ? Form1 _form;
? ? ? ? public MyRequestHandler(Form1 form)
? ? ? ? {
? ? ? ? ? ? _form = form;
? ? ? ? }
? ? ? ? public static string AuthorizationValue;
? ? ? ? protected override bool OnBeforeBrowse(IWebBrowser chromiumWebBrowser, IBrowser browser, IFrame frame, IRequest request, bool userGesture,
? ? ? ? ? ? bool isRedirect)
? ? ? ? {
? ? ? ? ? ? // 先調(diào)用基類的實(shí)現(xiàn)，斷點(diǎn)調(diào)試
? ? ? ? ? ? return base.OnBeforeBrowse(chromiumWebBrowser, browser, frame, request, userGesture, isRedirect);
? ? ? ? }
? ? ? ? protected override IResourceRequestHandler GetResourceRequestHandler(IWebBrowser chromiumWebBrowser, IBrowser browser, IFrame frame,
? ? ? ? ? ? IRequest request, bool isNavigation, bool isDownload, string requestInitiator, ref bool disableDefaultHandling)
? ? ? ? {
? ? ? ? ? ? Console.WriteLine(request.Url);
? ? ? ? ? ? if (request.Url.StartsWith("https://www.xxxxxxxxxxxxxxxx/api") && request.Headers.AllKeys.Contains("Authorization"))
? ? ? ? ? ? {
? ? ? ? ? ? ? ? AuthorizationValue = request.Headers["Authorization"];
? ? ? ? ? ? }
? ? ? ? ? ? return new MyResourceRequestHandler(_form);
? ? ? ? }
? ? }4.最后ResourceRequestHandler攔截到ajax請求之后，如果結(jié)果不是AVALIABLE則通過StartListenFunc再次恢復(fù)線程
? ? public class MyResourceRequestHandler : ResourceRequestHandler
? ? {
? ? ? ? Form1 _form;
? ? ? ? public MyResourceRequestHandler(Form1 form)
? ? ? ? {
? ? ? ? ? ? _form = form;
? ? ? ? }
? ? ? ? private Dictionary<ulong, MemoryStreamResponseFilter> responseDictionary = new Dictionary<ulong, MemoryStreamResponseFilter>();
? ? ? ? protected override IResponseFilter GetResourceResponseFilter(IWebBrowser browserControl, IBrowser browser, IFrame frame, IRequest request, IResponse response)
? ? ? ? {
? ? ? ? ? ? var dataFilter = new MemoryStreamResponseFilter();
? ? ? ? ? ? responseDictionary.Add(request.Identifier, dataFilter);
? ? ? ? ? ? return dataFilter;
? ? ? ? }
? ? ? ? protected override void OnResourceLoadComplete(IWebBrowser browserControl, IBrowser browser, IFrame frame, IRequest request, IResponse response, UrlRequestStatus status, long receivedContentLength)
? ? ? ? {
? ? ? ? ? ? MemoryStreamResponseFilter filter;
? ? ? ? ? ? if (responseDictionary.TryGetValue(request.Identifier, out filter))
? ? ? ? ? ? {
? ? ? ? ? ? ? ? var data = filter.Data;
? ? ? ? ? ? ? ??
? ? ? ? ? ? ? ? if (request.Url.StartsWith("https://xxxxxxxxxxxxxxxxxxxx/oneapi"))
? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? var available = false;
? ? ? ? ? ? ? ? ? ? string s = System.Text.Encoding.UTF8.GetString(data, 0, data.Length);
? ? ? ? ? ? ? ? ? ? Console.WriteLine(s);
? ? ? ? ? ? ? ? ? ? if (!string.IsNullOrEmpty(s))
? ? ? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? ? ? var responseData = JsonConvert.DeserializeObject<ScheduleResponse>(s);
? ? ? ? ? ? ? ? ? ? ? ? if (responseData != null && responseData.productPreviews != null)
? ? ? ? ? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? ? ? ? ? foreach (var item in responseData.productPreviews)
? ? ? ? ? ? ? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? if (item.schedule != null && item.schedule.status != null && item.schedule.status.name == "AVAILABLE")
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? available = true;
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? Mp3Player.Play();
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? Action act = delegate () { _form.StopListen(); };
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? _form.Invoke(act);
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? break;
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? if (!available && Form1.StartListen)
? ? ? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? ? ? Form1.StartListenFunc();
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ??
? ? ? ? ? ? ? ? filter.Dispose();
? ? ? ? ? ? }
? ? ? ? }
? ? }而StartListenFunc則是通過Set方法再次恢復(fù)了線程對ui的重復(fù)查詢
? ? ? ? public static void StartListenFunc()
? ? ? ? {
? ? ? ? ? ? _eventBeginListenWorkList.Set();
? ? ? ? ? ? StartListen = true;
? ? ? ? }ManualResetEvent官方介紹如下
https://docs.microsoft.com/zh-cn/dotnet/api/system.threading.manualresetevent?view=netframework-1.1
到此這篇關(guān)于C#中ManualResetEvent實(shí)現(xiàn)線程的暫停與恢復(fù)的文章就介紹到這了,更多相關(guān)C# 線程暫停恢復(fù)內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
C#中使用Interlocked進(jìn)行原子操作的技巧
使用.NET提供的Interlocked類可以對一些數(shù)據(jù)進(jìn)行原子操作，看起來似乎跟lock鎖一樣，但它并不是lock鎖，它的原子操作是基于CPU本身的，非阻塞的，所以要比lock的效率高2016-12-12
C#實(shí)現(xiàn)改變DataGrid某一行和單元格顏色的方法
這篇文章主要介紹了C#實(shí)現(xiàn)改變DataGrid某一行和單元格顏色的方法,主要涉及DataGrid控件的添加與使用、數(shù)據(jù)源的綁定、單元格與行的獲取等操作。需要的朋友可以參考下2014-09-09
10個C#程序員經(jīng)常用到的實(shí)用代碼片段
如果你是一個C#程序員，那么本文介紹的10個C#常用代碼片段一定會給你帶來幫助，從底層的資源操作，到上層的UI應(yīng)用，這些代碼也許能給你的開發(fā)節(jié)省不少時間。以下是原文：2015-09-09
這篇文章主要介紹了C# 使用GDI繪制雷達(dá)圖，本文通過一段實(shí)例代碼給大家介紹的非常詳細(xì)，具有一定的參考借鑒價值,需要的朋友可以參考下2019-11-11
C#實(shí)現(xiàn)自定義FTP操作封裝類實(shí)例
這篇文章主要介紹了C#實(shí)現(xiàn)自定義FTP操作封裝類,涉及C#操作FTP的連接、傳輸、下載等操作的實(shí)現(xiàn)技巧,非常具有實(shí)用價值,需要的朋友可以參考下2015-03-03
今天小編就為大家分享一篇關(guān)于C#將Excel轉(zhuǎn)成PDF的方法，小編覺得內(nèi)容挺不錯的，現(xiàn)在分享給大家，具有很好的參考價值，需要的朋友一起跟隨小編來看看吧2019-01-01
這篇文章主要介紹了C#判斷本地文件是否處于打開狀態(tài)的方法,涉及C#操作文件的技巧,非常具有實(shí)用價值,需要的朋友可以參考下2015-05-05
C#使用Socket實(shí)現(xiàn)服務(wù)器與多個客戶端通信(簡單的聊天系統(tǒng))
這篇文章主要介紹了C#使用Socket實(shí)現(xiàn)服務(wù)器與多個客戶端通信(簡單的聊天系統(tǒng))，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-02-02
本文詳細(xì)講解了使用Log4net進(jìn)行日志記錄的方法，文中通過示例代碼介紹的非常詳細(xì)。對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值，需要的朋友可以參考下2021-12-12
這篇文章介紹了C#入門之結(jié)構(gòu)類型Struct，文中通過示例代碼介紹的非常詳細(xì)。對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值，需要的朋友可以參考下2022-05-05