我所提到服務器程序是指能夠接受客戶請求並能處理請求的程序，而不只是指那些接受網絡客戶請求的網絡服務器程序。
多線程技術主要解決處理器單元內多個線程執行的問題，它可以顯著減少處理器單元的閒置時間，增加處理器單元的吞吐能力。但如果對多線程應用不當，會增加對單個任務的處理時間。可以舉一個簡單的例子：
假設在一台服務器完成一項任務的時間為T
T1 創建線程的時間
T2 在線程中執行任務的時間，包括線程間同步所需時間
T3 線程銷毀的時間
顯然T ＝ T1＋T2＋T3。注意這是一個極度簡化的假設。
可以看出T1,T3是多線程本身的帶來的開銷，我們渴望減少T1,T3所用的時間，從而減少T的時間。但一些線程的使用者並沒有注意到這一點，所以在程序中頻繁的創建或銷毀線程，這導致T1和T3在T中占有相當比例。顯然這是突出了線程的弱點（T1，T3），而不是優點（並發性）。
線程池技術正是關注如何縮短或調整T1,T3時間的技術，從而提高服務器程序性能的。它把T1，T3分別安排在服務器程序的啟動和結束的時間段或者一些空閒的時間段，這樣在服務器程序處理客戶請求時，不會有T1，T3的開銷了。
線程池不僅調整T1,T3產生的時間段，而且它還顯著減少了創建線程的數目。在看一個例子：
假設一個服務器一天要處理50000個請求，並且每個請求需要一個單獨的線程完成。我們比較利用線程池技術和不利於線程池技術的服務器處理這些請求時所產生的線程總數。在線程池中，線程數一般是固定的，所以產生線程總數不會超過線程池中線程的數目或者上限（以下簡稱線程池尺寸），而如果服務器不利用線程池來處理這些請求則線程總數為50000。一般線程池尺寸是遠小於50000。所以利用線程池的服務器程序不會為了創建50000而在處理請求時浪費時間，從而提高效率。
這些都是假設，不能充分說明問題，下面我將討論線程池的簡單實現並對該程序進行對比測試，以說明線程技術優點及應用領域。
一般一個簡單線程池至少包含下列組成部分。
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Collections;
using System.Threading;
namespace ThreadManager
{
public class ThreadPoolManager
{
private int MaxThreadNum;
private int MinThreadNum;
private int GrowStepNum;
//線程數量
public int ThreadNum{get;set;}
//默認線程數量
public int DefaultThreadNum { get; set; }
private Queue TaskQueue;
private Queue WorkThreadList;
public ThreadPoolManager(int i)
{
TaskQueue = new Queue();
WorkThreadList = new Queue();
DefaultThreadNum = 10;
if (i > 0)
DefaultThreadNum = i;
CreateThreadPool(i);
}
public ThreadPoolManager():this(10)
{
}
public bool IsAllTaskFinish()
{
return TaskQueue.Count == 0;
}
public void CreateThreadPool(int i)
{
if (WorkThreadList == null)
WorkThreadList = new Queue();
lock (WorkThreadList)
{
for (int j = 0; j < i;j++)
{
ThreadNum++;
WorkThread workthread = new WorkThread(ref TaskQueue,ThreadNum);
WorkThreadList.Enqueue(workthread);
}
}
}
public void AddTask(Task task)
{
if (task == null)
return;
lock (TaskQueue)
{
TaskQueue.Enqueue(task);
}
//Monitor.Enter(TaskQueue);
//TaskQueue.Enqueue(task);
//Monitor.Exit(TaskQueue);
}
public void CloseThread()
{
//Object obj = null;
while (WorkThreadList.Count != 0)
{
try
{
WorkThread workthread = WorkThreadList.Dequeue();
workthread.CloseThread();
continue;
}
catch (Exception)
{
}
break;
}
}
}
}
工作線程類using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
namespace ThreadManager
{
public class WorkThread
{
public int ThreadNum { get; set; }
private bool flag;
private Queue TaskQueue;
private Task task;
public WorkThread(ref Queue queue, int i)
{
this.TaskQueue = queue;
ThreadNum = i;
flag = true;
new Thread(run).Start();
}
public void run()
{
while (flag && TaskQueue != null)
{
//獲取任務
lock (TaskQueue)
{
try
{
task = TaskQueue.Dequeue();
}
catch (Exception)
{
task = null;
}
if (task == null)
continue;
}
try
{
task.SetEnd(false);
task.StartTask();
}
catch (Exception)
{
}
try
{
if (!task.IsEnd())
{
task.SetEnd(false);
task.EndTask();
}
}
catch (Exception)
{
}
}//end of while
}
public void CloseThread()
{
flag = false;
try
{
if (task != null)
task.EndTask();
}
catch (Exception)
{
}
}
}
} task類和實現類using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
namespace ThreadManager
{
public interface Task
{
///
/// set flag of task.
///
void SetEnd(bool flag);
///
/// start task.
///
void StartTask();
///
/// end task.
///
void EndTask();
///
/// get status of task.
///
///
