在一些耗時(shí)的操作過(guò)程中，在長(zhǎng)時(shí)間運(yùn)行時(shí)可能會(huì)導(dǎo)致用戶界面 (ui) 處于停止響應(yīng)狀態(tài)，用戶在這操作期間無(wú)法進(jìn)行其他的操作，為了不使ui層處于停止響應(yīng)狀態(tài)，我們傾向推薦用戶使用backgroundworker來(lái)進(jìn)行處理，這個(gè)后臺(tái)的線程處理，可以很好的實(shí)現(xiàn)常規(guī)操作的同時(shí)，還可以及時(shí)通知ui，包括當(dāng)前處理信息和進(jìn)度等，這個(gè)backgroundworker的處理在百度里面也是有很多使用的介紹，本篇隨筆主要是做一些自己的使用總結(jié)，希望也能給讀者提供一個(gè)參考。
在使用backgroundworker的過(guò)程中，我們可以定義自己的狀態(tài)參數(shù)信息，從而實(shí)現(xiàn)線程狀態(tài)的實(shí)時(shí)跟蹤以及進(jìn)度和信息提示，方便我們及時(shí)通知ui進(jìn)行更新。本篇隨筆主要針對(duì)一些數(shù)據(jù)采集過(guò)程的處理，在網(wǎng)上采集特定的數(shù)據(jù)往往需要耗時(shí)幾個(gè)小時(shí)以上，如果采用常規(guī)的同步操作，比較麻煩，而如果引入一些smartthreadpool這些第三方類庫(kù)有顯得臃腫，而且資源耗費(fèi)的也很嚴(yán)重，因此使用backgroundworker相對(duì)比較輕型的方案比較吸引我。
采集的數(shù)據(jù)處理
例如是我采集數(shù)據(jù)的一個(gè)局部界面，主要是根據(jù)一些參數(shù)進(jìn)行數(shù)據(jù)的采集，采集過(guò)程可以通過(guò)狀態(tài)欄和右邊的標(biāo)簽進(jìn)行反饋，在狀態(tài)欄顯示采集進(jìn)度等信息，實(shí)現(xiàn)比較友好的信息顯示。
一般我們定義后臺(tái)線程處理，可以在該窗體定義一個(gè)變量即可，如下代碼所示。
|
1
|
private backgroundworker worker = new backgroundworker(); |
然后就是對(duì)這個(gè)后臺(tái)線程處理對(duì)象的一些事件進(jìn)行實(shí)現(xiàn)即可，如下代碼所示
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
|
public partial class mainframe : baseform { /// <summary> /// 增加一個(gè)變量來(lái)記錄線程狀態(tài) /// </summary> private bool isthreadrunning = false; private backgroundworker worker = new backgroundworker(); public mainframe() { initializecomponent(); portal.gc.initdata(); worker.workersupportscancellation = true; //支持取消 worker.workerreportsprogress = true; //支持報(bào)告進(jìn)度 worker.dowork += worker_dowork; //處理過(guò)程 worker.runworkercompleted += worker_runworkercompleted; //完成操作 worker.progresschanged += worker_progresschanged; //報(bào)告進(jìn)度 } |
例如進(jìn)度條的通知，主要就是計(jì)算總?cè)蝿?wù)的數(shù)量，以及當(dāng)前完成的人數(shù)數(shù)量，我們實(shí)現(xiàn)代碼如下所示
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
|
/// <summary> /// 進(jìn)度條的通知 /// </summary> void worker_progresschanged(object sender, progresschangedeventargs e) { this.barprogress.editvalue = e.progresspercentage; collectstateinfo stateinfo = e.userstate as collectstateinfo; if (stateinfo != null) { var message = string.format("正在采集 {0} 的 {1} , 項(xiàng)目名稱為:{2}", stateinfo.totalrecords, stateinfo.completedrecord + 1, stateinfo.currentitemname); this.lbltips.text = message; this.bartips.caption = message; //記錄運(yùn)行位置 jobparameterhelper.savedata(new currentjobparameter(stateinfo)); } } |
這里我們看到了，這個(gè)里面使用了一個(gè)自定義的狀態(tài)參數(shù)collectstateinfo ，這個(gè)是我們用來(lái)在后臺(tái)進(jìn)程處理過(guò)程中傳遞的一個(gè)對(duì)象，可以記錄當(dāng)前采集的相關(guān)信息，collectstateinfo 類的定義如下所示。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
|
/// <summary> /// 狀態(tài)對(duì)象數(shù)據(jù) /// </summary> public class collectstateinfo { /// <summary> /// 當(dāng)前期數(shù)(年份+期數(shù)) /// </summary> public string yearqsnumber { get; set; } /// <summary> /// 任務(wù)開(kāi)始時(shí)間 /// </summary> public datetime starttime { get; set; } private datetime m_endtime = datetime.now; /// <summary> /// 任務(wù)開(kāi)始時(shí)間 /// </summary> public datetime endtime { get { return m_endtime; } set { //設(shè)置結(jié)束時(shí)間的時(shí)候，獲取耗時(shí) m_endtime = value; this.timespanused = value.subtract(this.starttime); } } /// <summary> /// 任務(wù)用時(shí) /// </summary> public timespan timespanused { get; set; } /// <summary> /// 任務(wù)數(shù)量 /// </summary> public int totalrecords { get; set; } private int m_completedrecord = 0; /// <summary> /// 完成數(shù)量 /// </summary> public int completedrecord { get { return m_completedrecord; } set { m_completedrecord = value; if (totalrecords > 0) { this.currentprogress = convert.toint32(value * 100.0 / totalrecords); } } } /// <summary> /// 當(dāng)前進(jìn)度 /// </summary> public int currentprogress { get; set; } /// <summary> /// 當(dāng)前采集的項(xiàng)目 /// </summary> public string currentitemname { get; set; } /// <summary> /// 默認(rèn)構(gòu)造函數(shù) /// </summary> /// <param name="total"></param> public collectstateinfo() { this.starttime = datetime.now; this.endtime = datetime.now; } /// <summary> /// 構(gòu)造函數(shù) /// </summary> /// <param name="total">任務(wù)數(shù)量</param> /// <param name="qsnumber">采集當(dāng)前期數(shù)</param> public collectstateinfo(int total, string qsnumber, int completed) :this() { this.totalrecords = total; this.yearqsnumber = qsnumber; this.completedrecord = completed; } } |
上面的對(duì)象，主要用來(lái)記錄任務(wù)的總數(shù)，以及當(dāng)前進(jìn)行的數(shù)量，還包括一些其他信息，如任務(wù)的開(kāi)始時(shí)間，結(jié)束時(shí)間等等，我們可以把一些常規(guī)的任務(wù)信息，放到這里面來(lái)傳遞即可。
另一個(gè)后臺(tái)進(jìn)程處理的關(guān)鍵事件就是處理過(guò)程的代碼實(shí)現(xiàn)，主要就是采集處理的邏輯內(nèi)容，如下所示。
|
1
2
3
4
5
6
7
8
9
10
|
void worker_dowork(object sender, doworkeventargs e) { collectstateinfo info = e.argument as collectstateinfo; if (info != null) { linkjob job = new linkjob(); var stateinfo = job.execute(this.worker, info); e.result = stateinfo; } } |
這個(gè)里面我么主要到它的e.argument 就是我們傳遞的對(duì)象，通過(guò)類型轉(zhuǎn)換我們就可以獲得對(duì)應(yīng)的信息，然后進(jìn)行具體的處理了。
另外一個(gè)就是當(dāng)整個(gè)后臺(tái)進(jìn)程完成處理后，我們需要進(jìn)行相關(guān)的提示和狀態(tài)處理，實(shí)現(xiàn)代碼如下所示。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
|
void worker_runworkercompleted(object sender, runworkercompletedeventargs e) { //還原按鈕狀態(tài) initcollectstate(); isthreadrunning = false; string message = "采集操作完成"; collectstateinfo stateinfo = e.result as collectstateinfo; if (stateinfo != null && stateinfo.completedrecord == stateinfo.totalrecords) { message += string.format("，完成采集網(wǎng)址{0}個(gè),耗時(shí)為：{1}分鐘{2}秒。", stateinfo.totalrecords, stateinfo.timespanused.minutes, stateinfo.timespanused.seconds); //清空數(shù)據(jù)即可 jobparameterhelper.cleardata(); } else { message += string.format("，用戶取消處理,耗時(shí)為：{1}分鐘{2}秒。", stateinfo.totalrecords, stateinfo.timespanused.minutes, stateinfo.timespanused.seconds); } messagedxutil.showtips(message); } |
而我們開(kāi)始任務(wù)，則通過(guò)按鈕觸發(fā)后臺(tái)線程的異步接口調(diào)用即可，如下代碼所示。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
|
if (!worker.isbusy) { this.btnstartcollect.imageoptions.image = resources.button_stop; this.lbltips.text = "數(shù)據(jù)采集中....，單擊按鈕可停止采集"; this.btnstartcollect.text = "停止采集"; var totalcount = bllfactory<urllink>.instance.getrecordcount();//數(shù)量為總數(shù) var stateinfo = new collectstateinfo(totalcount, yearqsnumber, skipcount); worker.runworkerasync(stateinfo); //改變狀態(tài) isthreadrunning = !isthreadrunning; } |
這里面我們?cè)O(shè)置提示開(kāi)始采集數(shù)據(jù)后，然后構(gòu)建一個(gè)可以用于傳遞的線程采集對(duì)象給后臺(tái)線程，通過(guò)異步調(diào)用worker.runworkerasync(stateinfo); 即可實(shí)現(xiàn)任務(wù)的開(kāi)始操作。
如果任務(wù)總之，我們調(diào)用取消接口即可。
|
1
2
3
4
5
6
7
8
9
10
|
if (messagedxutil.showyesnoandwarning("采集正在進(jìn)行中，您確認(rèn)停止采集嗎？") == system.windows.forms.dialogresult.yes) { worker.cancelasync(); //改變狀態(tài) isthreadrunning = !isthreadrunning; //還原按鈕狀態(tài) initcollectstate(); } |
啟動(dòng)采集界面進(jìn)行相應(yīng)的處理即可，如下所示。
采集過(guò)程的進(jìn)度可以通過(guò)狀態(tài)欄實(shí)時(shí)的顯示出來(lái)，這個(gè)有賴于我們定義的狀態(tài)類，可以很方便進(jìn)行ui的信息通知。
以上就是使用后臺(tái)線程backgroundworker處理任務(wù)的一些總結(jié)，希望給讀者帶來(lái)一些參考價(jià)值，在我們做一些耗時(shí)的操作的時(shí)候，可以考慮使用這個(gè)后臺(tái)線程backgroundworker處理任務(wù)，從而實(shí)現(xiàn)較好的界面通知，也不會(huì)造成ui界面的停頓卡死狀態(tài)。希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持服務(wù)器之家。
原文鏈接：https://www.cnblogs.com/wuhuacong/p/9144424.html
