執行緒池 Thread Pooling

執行緒池(thread pooling)

如果你的應用程式擁有大量的執行緒並花費大量的時間阻塞在乙個wait handle上，那麼你要考慮使用執行緒池(thead pooling)來處理。執行緒池通過合併多個wait handle來節約等待的時間。當wait handle被啟用時，使用執行緒池你需要註冊乙個wait handle到乙個委託去執行。通過呼叫threadpool.registerwaitforsingleobject方法：

class test 
public static void go(object data, bool timedout)  }

對於wait handle和委託，registerwaitforsingleobject接受乙個"黑盒"物件並傳遞給你的委託（就像parameterizedthreadstart），超時設定和boolean標誌指示了關閉和迴圈的請求。所有進入池中的執行緒都被認為是後台執行緒，這就意味著它們不再由應用程式控制，而是由系統控制直到應用程式退出。

注意：如果這時候呼叫abort操作，可能會發生意想不到的情況。

你也可以通過呼叫queueuserworkitem方法使用執行緒池，指定委託並立即被執行。這時你不能在多工情況下儲存共享執行緒，但是可以得到另外的好處：執行緒池會保持乙個執行緒的總容量，當作業數超出容量時自動插入任務。

class test 
console.writeline("waiting for threads to complete..."); 
lock (workerlocker) 
console.writeline("complete!"); 
console.readline(); 
} public static void go(object instance)  } 
}

為了傳遞多個物件到目標方法，你必須定義乙個客戶物件幷包含所有屬性或通過呼叫非同步的委託。如go方法接受兩引數：

threadpool.queueuserworkitem (delegate (object notused) );

其他的方法可以使用非同步委託。

其實對於openexisting函式有兩個過載版本，

mutex.openexisting (string)

mutex.openexisting (string, mutexrights)

對於預設的第乙個函式其實是實現了第二個函式 mutexrights.synchronize|mutexrights.modify操作。

由於監視器的設計是基於.net框架，而mutex類是系統核心物件封裝了win32的乙個核心結構來實現互斥，並且互斥操作需要請求中斷來完成，因此在進行程序內線程同步的時候效能上要比互斥要好。

典型的使用mutex同步需要完成三個步驟的操作：1.開啟或者建立乙個mutex例項；2.呼叫waitone()來請求互斥物件；3.最後呼叫releasemutex來釋放互斥物件。

static public void addstring(string str)  }

需要注意的是，waitone和releasemutex必須成對出現，否則會導致程序死鎖的發生，這時系統（.net2.0）框架會丟擲abandonedmutexexception異常。

訊號量(semaphore)

訊號量就像乙個***：它有確切的容量，並被保鏢控制。一旦滿員，就沒有人能再進入，其他人必須在外面排隊。那麼在裡面離開乙個人後，隊頭的人就可以進入。訊號量的建構函式需要提供至少兩個引數-現有的人數和最大的人數。

訊號量的行為有點類似於mutex或是lock，但是訊號量沒有擁有者。任意執行緒都可以呼叫release來釋放訊號量而不像mutex和lock那樣需要執行緒得到資源才能釋放。

class semaphoretest 
static void go()  } 
}

執行緒池 Thread Pooling

執行緒執行緒池

執行緒執行緒池

mysql 執行緒池 c MySQL執行緒池

執行緒池 Thread Pooling

執行緒 執行緒池

執行緒 執行緒池

mysql 執行緒池 c MySQL執行緒池

相關推薦

執行緒執行緒池

執行緒執行緒池