基于多核編程的案例分析-文庫吧
2025-08-26 10:42 本頁面
【正文】 foreach ( Object Client in ClientSockets ) { ( (ClientHandler) Client ).Stop() 。 } 線程池 ? 當客戶端的連接多了以后，會嚴重影響系統(tǒng)性能。 ? 線程池的利用可以有效管理所產(chǎn)生的這些線程。減小開銷，增加性能。 ? 在線程池中將任務(wù)重新分配。 –線程池中線程數(shù)量有限制 –即使沒有限制，線程過多，也會使 CPU負載過大而死機。 // Schedule task again if ( amp。amp。 !bQuit ) (new WaitCallback(), SharedStateObj)。 else { ()。 ()。 // Deduct no. of clients by one (ref )。 (A client left, number of connections is {0}, ) 。 } // Signal main process if this is the last client connections // main thread requested to stop. if ( ! amp。amp。 == 0 ) ()。 用隊列管理多線程 任務(wù)處理 任務(wù)處理 任務(wù)處理 FIFO隊列結(jié)構(gòu) 客戶端請求任務(wù) 監(jiān)聽線程 當客戶端請求到達， 將請求放到隊列中。 class ClientConnectionPool { // Creates a synchronized wrapper around the Queue. private Queue SyncdQ = ( new Queue() )。 } class ClientService { const int NUM_OF_THREAD = 10。 private ClientConnectionPool ConnectionPool 。 private bool ContinueProcess = false 。 private Thread [ ] ThreadTask = new Thread[NUM_OF_THREAD] 。 public ClientService(ClientConnectionPool ConnectionPool) { this .ConnectionPool = ConnectionPool 。 } public void Start() { ContinueProcess = true 。 // Start threads to handle Client Task for ( int i = 0 。 i 。 i++) { ThreadTask[i] = new Thread( new ThreadStart() )。 ThreadTask[i].Start() 。 } } private void Process() { while ( ContinueProcess ) {
教學課件相關(guān)推薦
鄂ICP備17016276號-1