一個應(yīng)用場景,瀏覽器上傳一個文件,此文件后臺調(diào)用文件轉(zhuǎn)換,需要耗費相當(dāng)長的時間,這樣,如果是一個線程同步式的做下去,那么用戶在瀏覽器上感覺就是卡住了,卡卡卡卡,這里我們利用委托的BeginInvoke和EndInvoke方法操作線程,BeginInvoke方法可以使用線程異步地執(zhí)行委托所指向的方法。然后通過EndInvoke方法獲得方法的返回值(EndInvoke方法的返回值就是被調(diào)用方法的返回值),或是確定方法已經(jīng)被成功調(diào)用,說白了就是相當(dāng)于開個多線程,你用戶文件保存了之后,響應(yīng)返回,這個BeginInvoke異步去執(zhí)行委托方法,完了之后呢,再執(zhí)行你的異步回調(diào)函數(shù);
大概步驟
1:先把你要異步執(zhí)行的方法抽離出來;
2:定義一個該異步方法的委托;
3:在調(diào)用地方實例化這個委托;
4:調(diào)用此委托實例的BeginInvoke方法,在此方法里,前面填委托的參數(shù),接著是委托方法結(jié)束后的回調(diào)函數(shù);
5:寫委托的回調(diào)函數(shù),回調(diào)函數(shù)是固定的參數(shù)(IAsyncResultIR)在這個里面,可以獲取用戶定義的對象,它限定或包含關(guān)于異步操作的信息(AsyncState)然后調(diào)用EndInvoke,獲取到委托方法結(jié)束的返回值。
6:調(diào)用自定義的回調(diào)函數(shù);
還是看代碼吧:
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
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
|
public class anysFileChange { /// <summary> /// 文件change后,其對應(yīng)的業(yè)務(wù)邏輯所需要做的變動鎖調(diào)用的委托 /// 轉(zhuǎn)換完之后 會調(diào)用所執(zhí)行的函數(shù),用戶需要干什么,這個函數(shù)則交由用戶自己的邏輯完成 /// </summary> public static anysChangingHandlerCallBack _handler = null ; /// <summary> /// 轉(zhuǎn)換文件 /// </summary> /// <param name="filepath">文件路徑</param> /// <returns></returns> public static void ChangingFile( string filepath, string attachId) { //開啟異步轉(zhuǎn)換 DEGAsyncChangingFile acf = new DEGAsyncChangingFile(anysFileChange.AsyncChangeFileToswf); acf.BeginInvoke(filepath, attachId, anysFileChange.CallBackAsync, acf); } /// <summary> /// 異步函數(shù)執(zhí)行完后的的回調(diào)函數(shù) /// </summary> /// <param name="IR">異步結(jié)果 </param> /// <returns></returns> private static void CallBackAsync(IAsyncResult IR) { DEGAsyncChangingFile acf = (DEGAsyncChangingFile)IR.AsyncState; ResultObj result = (ResultObj)acf.EndInvoke(IR); //如果調(diào)用 文件轉(zhuǎn)換結(jié)束方法有定義 轉(zhuǎn)換結(jié)束需要做的委托那么執(zhí)行用戶定義的委托函數(shù) if (_handler != null && result != null ) { ///成功才執(zhí)行客戶自定義的回調(diào)函數(shù) if (result.changestaus == EnumChangeStatus.SUCCESS) { _handler(result.filepath, result.attachId); } } } /// <summary> /// 轉(zhuǎn)換文件 /// </summary> /// <param name="filepath">文件路徑</param> /// <returns>HSUFResultObj 返回結(jié)果對象</returns> private static ResultObj AsyncChangeFileToswf( string filepath, string attachId) { ResultObj res = new ResultObj(); //轉(zhuǎn)換動作 ConvertFile cf = new ConvertFile(); //cf這個類提供了一個寫日志的事件 注冊一個寫日志事件 cf.ConvertLog += new ConvertFile.ConvertLogHandler(Syslog); //這里的cf這個類提供的方法,僅僅利用里面的轉(zhuǎn)換方法算了 cf.Convert(filepath); if (cf.ChangeResult == EnumChangeStatus.SUCCESS) { res.attachId = attachId; res.filepath = filepath; res.changestaus = cf.ChangeResult; } else { res.changeMessage = cf.convertMessage; res.changestaus = cf.ChangeResult; } return res; } /// <summary> /// 供注冊的日志事件 /// </summary> /// <param name="messages"></param> private static void Syslog( string messages) { string separateLine = "\r\n============================================================================================\r\n" ; string log = string .Format( @"{0} {1} {2} {0}" , separateLine, DateTime.Now.ToString(), messages); // 如果上傳課程文件夾不存在,則創(chuàng)建 if (!Directory.Exists(ConverConst.toolpath + "Log\\" )) Directory.CreateDirectory(ConverConst.toolpath + "Log\\" ); StreamWriter sw = new StreamWriter(ConverConst.toolpath+ "Log\\" +DateTime.Now.ToString( "yyyy-MM-dd" )+ ".txt" , true ); sw.WriteLine(log); sw.Close(); } /// <summary> /// 文件轉(zhuǎn)換委托 /// </summary> /// <param name="filepath">文件路徑</param> /// <returns> </returns> private delegate object DEGAsyncChangingFile( string filepath, string attachId); } /// <summary> /// 結(jié)果集對象 /// </summary> public class ResultObj { /// <summary> /// 文件路徑 /// </summary> public string filepath; /// <summary> /// id /// </summary> public string attachId; /// <summary> /// 轉(zhuǎn)換結(jié)果消息 /// </summary> public string changeMessage; /// <summary> /// 轉(zhuǎn)換狀態(tài) /// </summary> public EnumChangeStatus changestaus; } /// <summary> /// 文件轉(zhuǎn)換后,業(yè)務(wù)邏輯所需要調(diào)用的委托 /// </summary> /// <param name="filepath">文件路徑</param> public delegate void anysChangingHandlerCallBack( string filepath, string attchid); |
總結(jié)
以上就是這篇文章的全部內(nèi)容了,希望本文的內(nèi)容對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,謝謝大家對服務(wù)器之家的支持。如果你想了解更多相關(guān)內(nèi)容請查看下面相關(guān)鏈接
原文鏈接:https://blog.csdn.net/chenqiangdage/article/details/49910483