快捷導(dǎo)航

C#中ManualResetEvent實(shí)現(xiàn)線程的暫停與恢復(fù)

更新時(shí)間：2022年01月20日 11:35:29 作者：chester·chen

本文主要介紹了C#中ManualResetEvent實(shí)現(xiàn)線程的暫停與恢復(fù)，文中通過(guò)示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下

背景

前些天遇到一個(gè)需求，在沒(méi)有第三方源碼的情況下，刷新一個(gè)第三方UI，并且攔截到其ajax請(qǐng)求的返回結(jié)果。當(dāng)結(jié)果為AVALIABLE的時(shí)候，停止刷新并語(yǔ)音提示，否則繼續(xù)刷新。

分析這個(gè)需求，發(fā)現(xiàn)需要控制一個(gè)刷新循環(huán)的暫停與開(kāi)始，因此網(wǎng)上搜到了通過(guò)ManualResetEvent實(shí)現(xiàn)線程的暫停與恢復(fù)。

ManualResetEvent介紹

ManualResetEvent是一個(gè)通過(guò)信號(hào)機(jī)制，實(shí)現(xiàn)線程間狀態(tài)同步的類(lèi)。常用的方法有以下三個(gè)：

WaitOne：阻止當(dāng)前線程，直到收到信號(hào)
Reset：將事件狀態(tài)設(shè)置為非終止?fàn)顟B(tài)，導(dǎo)致線程阻止
Set：將事件狀態(tài)設(shè)置為終止?fàn)顟B(tài)，從而允許繼續(xù)執(zhí)行一個(gè)或多個(gè)等待線程

實(shí)現(xiàn)設(shè)計(jì)

1.通過(guò)CefSharp的谷歌瀏覽器插件請(qǐng)求第三方網(wǎng)站

2.具體交互邏輯如下

默認(rèn)開(kāi)啟一個(gè)線程，并通過(guò)WaitOne掛起，等待手動(dòng)開(kāi)始自動(dòng)刷新的指令
手動(dòng)通過(guò)Set方法發(fā)送開(kāi)始工作信號(hào)
執(zhí)行完面操作后，通過(guò)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";
? ? ? ? ? ? // 避免頁(yè)面加載不出來(lái), 建議加上這句
? ? ? ? ? ? Cef.Initialize(setting);

? ? ? ? ? ? workerThread = new Thread(new ThreadStart(BeginListenWorkerAsync));
? ? ? ? ? ? workerThread.IsBackground = true;
? ? ? ? ? ? workerThread.Start();

? ? ? ? ? ? this.停止自動(dòng)監(jiān)聽(tīng)ToolStripMenuItem.Enabled = false;
? ? ? ? }

? ? ? ? private async void BeginListenWorkerAsync()
? ? ? ? {
? ? ? ? ? ? while (true)
? ? ? ? ? ? {
? ? ? ? ? ? ? ? _eventBeginListenWorkList.WaitOne(); ?//1.默認(rèn)掛起線程，等待信號(hào)
? ? ? ? ? ? ? ? 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.頁(yè)面執(zhí)行完相應(yīng)操作則再次掛起線程，等待ajax請(qǐng)求結(jié)果再判斷是否恢復(fù)線程
? ? ? ? ? ? }
? ? ? ? }

? ? ? ? private void 停止自動(dòng)監(jiān)聽(tīng)ToolStripMenuItem_Click(object sender, EventArgs e)
? ? ? ? {
? ? ? ? ? ? this.開(kāi)始自動(dòng)監(jiān)聽(tīng)ToolStripMenuItem.Enabled = true;
? ? ? ? ? ? this.停止自動(dòng)監(jiān)聽(tīng)ToolStripMenuItem.Enabled = false;
? ? ? ? ? ? _eventBeginListenWorkList.Reset();
? ? ? ? ? ? StartListen = false;
? ? ? ? }

? ? ? ? private void 開(kāi)始自動(dòng)監(jiān)聽(tīng)ToolStripMenuItem_Click(object sender, EventArgs e)
? ? ? ? {
? ? ? ? ? ? this.開(kāi)始自動(dòng)監(jiān)聽(tīng)ToolStripMenuItem.Enabled = false;
? ? ? ? ? ? this.停止自動(dòng)監(jiān)聽(tīng)ToolStripMenuItem.Enabled = true;
? ? ? ? ? ? _eventBeginListenWorkList.Set(); // 2.手動(dòng)通過(guò)Set發(fā)送信號(hào)恢復(fù)線程，讓其工作
? ? ? ? ? ? StartListen = true;
? ? ? ? }

3.現(xiàn)在我們需要定義RequestHandler來(lái)指定ResourceHandler攔截ajax請(qǐng)求

? ? ? ? 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)用基類(lèi)的實(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請(qǐng)求之后，如果結(jié)果不是AVALIABLE則通過(guò)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則是通過(guò)Set方法再次恢復(fù)了線程對(duì)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)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: