多執行緒程式設計學習筆記執行緒池（三）

接上文多執行緒程式設計學習筆記——執行緒池（一）

接上文多執行緒程式設計學習筆記——執行緒池（二）

執行緒池還有乙個threadpool.registerwaitforsingleobject，這個方法允許我們將**函式放入執行緒池中的佇列中。當提供的等待事件處理器接收到訊號或發生超時時，這個**函式將被呼叫，這樣就實現了為執行緒池中操作實現超時操作。

1.**如下：

using
system;
using
system.collections.generic;
using
system.diagnostics;
using
system.linq;
using
system.text;
using
system.threading;
namespace
threadtpldemo
private
static
void
timesoperation(timespan  worktimes)} }
private
static
void
asyncoper(cancellationtoken token,manualresetevent mrevt)
", thread.currentthread.managedthreadid);
return
;                }
thread.sleep(timespan.fromseconds(
1));
}mrevt.set();
console.writeline(
"-------執行緒池中的第乙個工作執行緒 發出訊號----------");
}private
static
void asyncoperwait(cancellationtokensource cts, bool
istimeout)
", thread.currentthread.managedthreadid);
}else}}
}

2.程式結果如下。

程式啟動之後按順序放入了一些長時間執行的操作，這個操作執行6秒，如果執行成功，則會設定乙個manualresetevent訊號。如果取消了這個操作，則這個操作會被丟棄。

我們還註冊了第二個非同步操作，當從manualresetevent物件中接受了乙個訊號之後，這個非同步操作會被呼叫。如果第乙個操作順利執行，則會設定訊號。如果第乙個操作執行超時，則會通過cancellationtoken來取消第乙個操作。

注：當執行緒池中大量的操作被阻塞時，上面的方法就非常有用了。

六、使用計時器

使用threading.timer物件實現執行緒池中的週期性呼叫的非同步操作。

1.**如下：

using
system;
using
system.collections.generic;
using
system.diagnostics;
using
system.linq;
using
system.text;
using
system.threading; 
namespace
threadpooldemo
console.read();
}private
static
void
timesoperation(datetime starttime)
從  開始 執行了  秒",
thread.currentthread.managedthreadid, starttime.tostring(
"yyyy-mm-dd hh:mm:ss
"), time.seconds); }}
}

2.程式執行結果如下。

七、使用backgroundworker元件

本示例使用backgroundworker元件實現非同步操作。

程式啟動時建立了乙個backgroundworker物件例項，顯示的指示這個後台工作執行緒支援取消操作及操作進度通知。

1.**如下：

using
system;
using
system.collections.generic;
using
system.componentmodel;
using
system.diagnostics;
using
system.linq;
using
system.text;
using
system.threading;
namespace
threadtpldemo
} while
(bgwork.isbusy);       
console.read(); 
}static
void worker_dowork(object
sender,doworkeventargs e)
開始 執行",
thread.currentthread.managedthreadid);
int result = 0
;            
var bgwork =(backgroundworker)sender;
for (int i = 0; i < 100; i++)
if (i%10==0
)                
thread.sleep(
200);
result +=i;
}e.result =result;
}static
void worker_progresschanged(object
sender,progresschangedeventargs e)
已經完成工作量的  %
",          thread.currentthread.managedthreadid,e.progresspercentage);
}static
void worker_completed(object
sender,runworkercompletedeventargs e)
已經執行結束！",
thread.currentthread.managedthreadid);
if (e.error!=null
)             發生錯誤，錯誤資訊：",
thread.currentthread.managedthreadid,e.error.message);
}else
if(e.cancelled)
已經取消",
thread.currentthread.managedthreadid);
}else
執行成功，結果是：",
thread.currentthread.managedthreadid, e.result);}}
}}

2.程式正常執行結束，如下圖。

程式執行的中途，人工干預，取消。如下圖。請看下圖中黃框的位置，我輸入了字母c，則執行緒被取消。

在程式中我們定義了三個事件。

progresschanged事件，通過接收backgroundworker的reportprogress方法傳遞過來的引數，顯示執行緒執行的進度。

runworkercompleted事件，在此事件中可以知道操作是成功完成，還是發生了錯誤，或是被取消。

多執行緒程式設計學習筆記執行緒池（三）

執行緒池多執行緒學習筆記（三）

多執行緒程式設計學習筆記執行緒池（一）

多執行緒程式設計執行緒池 threadpool

多執行緒程式設計學習筆記 執行緒池（三）

執行緒池 多執行緒學習筆記（三）

多執行緒程式設計學習筆記 執行緒池（一）

多執行緒程式設計 執行緒池 threadpool

相關推薦

多執行緒程式設計學習筆記執行緒池（三）

執行緒池多執行緒學習筆記（三）

多執行緒程式設計學習筆記執行緒池（一）

多執行緒程式設計執行緒池 threadpool