第六节： TList 与泛型
TList 是一个重要的容器，用途广泛，配合泛型，更是如虎添翼。
我们先来改进一下带泛型的 TList 基类，以便以后使用。
本例源码下载(delphi XE8版本): FooList.Zip
unit uFooList;
interfaceuses Generics.Collections;
type TFooList <T>= class(TList<T>)
private
procedure FreeAllItems;
protected
procedure FreeItem(Item: T);virtual;
// 子类中需要重载此过程。以确定到底如何释放 Item
// 如果是 Item 是指针，就用 Dispose(Item);
// 如果是 Item 是TObject ，就用 Item.free;
public
destructor Destroy;override;
procedure ClearAllItems;
procedure Lock; // 给本类设计一把锁。
procedure Unlock;
end;
// 定义加入到 List 的 Item 都由 List 来释放。
// 定义释放规则很重要！只有规则清楚了，才不会乱套。
// 通过这样简单的改造， TList 立马好用 N 倍。
implementation{ TFooList<T> }procedure TFooList<T>.ClearAllItems;
begin FreeAllItems;
Clear;
end;
destructor TFooList<T>.Destroy;
begin FreeAllItems;
inherited;
end;
procedure TFooList<T>.FreeAllItems;
var Item: T;
begin for Item in self do
FreeItem(Item);
end;
procedure TFooList<T>.FreeItem(Item: T);
beginend;
procedure TFooList<T>.Lock;
begin System.TMonitor.Enter(self);
end;
procedure TFooList<T>.Unlock;
begin System.TMonitor.Exit(self);
end;
end.
将第五节的例子用 TFooList 改写：
unit uFrmMain; interface uses Winapi.Windows, Winapi.Messages, System.SysUtils, System.Variants, System.Classes, Vcl.Graphics,
Vcl.Controls, Vcl.Forms, Vcl.Dialogs, Vcl.StdCtrls, uCountThread, uFooList;
type TCountThreadList = Class(TFooList<TCountThread>) // 定义一个线程 List
protected
procedure FreeItem(Item: TCountThread); override; // 指定 Item 的释放方式。
end;
TNumList = Class(TFooList<Integer>); // 定义一个 Integer List
TFrmMain = class(TForm)
memMsg: TMemo;
edtNum: TEdit;
btnWork: TButton;
lblInfo: TLabel;
procedure FormCreate(Sender: TObject);
procedure FormDestroy(Sender: TObject);
procedure btnWorkClick(Sender: TObject);
procedure FormCloseQuery(Sender: TObject; var CanClose: Boolean);
private
{ Private declarations }
FNumList: TNumList;
FCountThreadList: TCountThreadList;
FBuff: TStringList;
FBuffIndex: Integer;
FBuffMaxIndex: Integer;
FWorkedCount: Integer;
procedure DispMsg(AMsg: string);
procedure OnThreadMsg(AMsg: string);
function OnGetNum(Sender: TCountThread): Boolean;
procedure OnCounted(Sender: TCountThread);
procedure LockCount;
procedure UnlockCount;
public
{ Public declarations }
end;
var FrmMain: TFrmMain;
implementation{$R *.dfm}
{ TFrmMain }{ TCountThreadList }procedure TCountThreadList.FreeItem(Item: TCountThread);
begin inherited;
Item.Free;
end;
procedure TFrmMain.btnWorkClick(Sender: TObject);
var s: string;
thd: TCountThread;
begin btnWork.Enabled := false;
FWorkedCount := 0;
FBuffIndex := 0;
FBuffMaxIndex := FNumList.Count - 1;
s := '共' + IntToStr(FBuffMaxIndex + 1) + '个任务,已完成:' + IntToStr(FWorkedCount);
lblInfo.Caption := s;
for thd in FCountThreadList do
begin
thd.StartThread;
end;
end;
procedure TFrmMain.DispMsg(AMsg: string);
begin memMsg.Lines.Add(AMsg);
end;
procedure TFrmMain.FormCloseQuery(Sender: TObject; var CanClose: Boolean);
begin // 防止计算期间退出
LockCount; // 请思考，这里为什么要用 LockCount;
CanClose := btnWork.Enabled;
if not btnWork.Enabled then
DispMsg('正在计算，不准退出!');
UnlockCount;
end;
procedure TFrmMain.FormCreate(Sender: TObject);
var thd: TCountThread;
i: Integer;
begin FCountThreadList := TCountThreadList.Create;
// 可以看出用了 List 之后，线程数量指定更加灵活。
// 多个线程在一个 List 中，这个 List 可以理解为线程池。
for i := 1 to 3 do
begin
thd := TCountThread.Create(false);
FCountThreadList.Add(thd);
thd.OnStatusMsg := self.OnThreadMsg;
thd.OnGetNum := self.OnGetNum;
thd.OnCounted := self.OnCounted;
thd.ThreadName := '线程' + IntToStr(i);
end;
FNumList := TNumList.Create;
// 构造一组数据用来测试
FNumList.Add(100);
FNumList.Add(136);
FNumList.Add(306);
FNumList.Add(156);
FNumList.Add(152);
FNumList.Add(106);
FNumList.Add(306);
FNumList.Add(156);
FNumList.Add(655);
FNumList.Add(53);
FNumList.Add(99);
FNumList.Add(157);
end;
procedure TFrmMain.FormDestroy(Sender: TObject);
begin FNumList.Free;
FCountThreadList.Free;
end;
procedure TFrmMain.LockCount;
begin System.TMonitor.Enter(btnWork);
end;
procedure TFrmMain.UnlockCount;
begin System.TMonitor.Exit(btnWork);
end;
procedure TFrmMain.OnCounted(Sender: TCountThread);
var s: string;
begin LockCount;
// 锁不同的对象，宜用不同的锁。
// 每把锁的功能要单一，锁的粒度要最小化。才能提高效率。
s := Sender.ThreadName + ':' + IntToStr(Sender.Num) + '累加和为:';
s := s + IntToStr(Sender.Total);
OnThreadMsg(s);
inc(FWorkedCount);
s := '共' + IntToStr(FBuffMaxIndex + 1) + '个任务,已完成:' + IntToStr(FWorkedCount);
TThread.Synchronize(nil,
procedure
begin
lblInfo.Caption := s;
end);
if FWorkedCount >= FBuffMaxIndex + 1 then
begin
TThread.Synchronize(nil,
procedure
begin
DispMsg('已计算完成');
btnWork.Enabled := true; // 恢复按钮状态。
end);
end;
UnlockCount;
end;
function TFrmMain.OnGetNum(Sender: TCountThread): Boolean;
begin // 将多个线程访问 FNumList 排队。
FNumList.Lock;
try
if FBuffIndex > FBuffMaxIndex then
begin
result := false;
end
else
begin
Sender.Num := FNumList[FBuffIndex];
result := true;
inc(FBuffIndex);
end;
finally
FNumList.Unlock;
end;
end;
procedure TFrmMain.OnThreadMsg(AMsg: string);
begin TThread.Synchronize(nil,
procedure
begin
DispMsg(AMsg);
end);
end;
end.
通过这五节学习，相信大家已能掌握 delphi 线程的用法了。
下一节课程内容，我们将利用 TFooList 设计更高级实用的线程工具。也是本线程教程的完结篇。