当前位置：文档之家 › Delphi_多线程实例高级

Delphi_多线程实例高级

  • 格式：doc
  • 大小：38.50 KB
  • 文档页数：5

Delphi 多线程实例下面笔者将介绍一个简单的实例，解释和说明前面所述的内容。

1）建立Form，在其中建立两个按钮“开始采集”和“停止采集”，添加一个PaintBox1。

2）建立一个新的单元，在其中输入以下代码：unit CollectThread;interfaceusesClasses,SysUtils,stdctrls,Graphics;typeTCollectDataThread = class(TThread)privateFPreSetTime:Word;FUsedTime:integer;FCanvas:TCanvas;protectedprocedure Execute; override;procedure ShowData;publicCollectData:array[0..1023]of integer;constructor Create(PresetTime:Word;Canvas:TCanvas);end;implementation{TCollectDataThread}constructor TCollectDataThread.Create(PreSetTime:Word;Canvas:TCanvas);var i:integer;beginfor i:=0 to 1023 do CollectData[i]:=0; // 给数据赋初值FCanvas:=Canvas;FPreSetTime:=PreSetTime; // 预置采集次数FUsedTime:=0; // 已经采集的次数inherited Create(true);FreeOnTerminate := True; //当线程终止时自动释放该线程end;procedure TCollectDataThread.Execute;varflag:Byte;address:Byte;i:integer;beginwhile FUsedTime < FPresetTime dobeginFUsedTime:=FUsedTime+1;flag:=0; // 数据准备好标志{由于您在调试程序时没有硬件支持，所以建议您使用下面的这段程序来模拟硬件的工作，}for i:=0 to 9000000 do //产生迟延，flag:=i;if flag>0 thenbeginCollectData[FUsedTime]:=round(50.0*sin(3.1415/50*FUsedTime));Synchronize(ShowData); //同步调用数据显示函数end;{实际上从硬件中采集数据最常用的是如下形式，但是这段程序正常工作需要相应的I/O接口设支持，所以它仅共参考}{repeatbeginflag:=inportb($341); // 数据是否准备好标志flag:=flag and $c0;if (flag=0) then // 如果AD转换的数据准备好beginCollectData[FUsedTime]:=inportw($342);end;flag:=flag and $10; // 恢复数据准备好标志end; // end while not flag=0until(flag=0);Synchronize(ShowData); //同步调用数据显示函数}end; //while FUsedtime<FPresetTimeDoTerminate; //时间到后线程终止end;// 在指定的画布上显示采集到的数据；procedure TCollectDataThread.ShowData;beginFCanvas.Pixels[2*FUsedTime,80+CollectData[FUsedTime]]:=clRed;end;end.3）在Form的单元文件中声明变量CollTestThread:TCollectDataThread，并在Form的OnCreate事件中加入以下代码：CollTestThread:= TCollectDataThread.Create(500,PaintBox1.Canvas);4）在“开始采集”按钮的OnClick事件中加入以下代码：CollTestThread.Resume;5）在“暂停采集”按钮的OnClick事件中加入以下代码：CollTestThread.Suspend;用户可以利用前面所提到的Synchronize函数来窗体，或者使用定时器定期刷新屏幕，这两种方式都可以间隔一定时间显示采集数据情况。

6、结束语采用上面所述的方法，笔者实现了对心电谱数据的采集和显示，达到了很好的效果。

本方法尤其适用于那些利用计算机I/O插槽来实现数据采集的硬件设备，串口通信中的采集方法也与上述思想相类似。

鉴于笔者的水平有限，欢迎读者批评指正文章中的不足之处。

Delphi 多线程实例下面笔者将介绍一个简单的实例，解释和说明前面所述的内容。

1）建立Form，在其中建立两个按钮“开始采集”和“停止采集”，添加一个PaintBox1。

2）建立一个新的单元，在其中输入以下代码：unit CollectThread;interfaceusesClasses,SysUtils,stdctrls,Graphics;typeTCollectDataThread = class(TThread)privateFPreSetTime:Word;FUsedTime:integer;FCanvas:TCanvas;protectedprocedure Execute; override;procedure ShowData;publicCollectData:array[0..1023]of integer;constructor Create(PresetTime:Word;Canvas:TCanvas);end;implementation{TCollectDataThread}constructor TCollectDataThread.Create(PreSetTime:Word;Canvas:TCanvas);var i:integer;beginfor i:=0 to 1023 do CollectData[i]:=0; // 给数据赋初值FCanvas:=Canvas;FPreSetTime:=PreSetTime; // 预置采集次数FUsedTime:=0; // 已经采集的次数inherited Create(true);FreeOnTerminate := True; //当线程终止时自动释放该线程end;procedure TCollectDataThread.Execute;varflag:Byte;address:Byte;i:integer;beginwhile FUsedTime < FPresetTime dobeginFUsedTime:=FUsedTime+1;flag:=0; // 数据准备好标志{由于您在调试程序时没有硬件支持，所以建议您使用下面的这段程序来模拟硬件的工作，}for i:=0 to 9000000 do //产生迟延，flag:=i;if flag>0 thenbeginCollectData[FUsedTime]:=round(50.0*sin(3.1415/50*FUsedTime));Synchronize(ShowData); //同步调用数据显示函数end;{实际上从硬件中采集数据最常用的是如下形式，但是这段程序正常工作需要相应的I/O接口设支持，所以它仅共参考}{repeatbeginflag:=inportb($341); // 数据是否准备好标志flag:=flag and $c0;if (flag=0) then // 如果AD转换的数据准备好beginCollectData[FUsedTime]:=inportw($342);end;flag:=flag and $10; // 恢复数据准备好标志end; // end while not flag=0until(flag=0);Synchronize(ShowData); //同步调用数据显示函数}end; //while FUsedtime<FPresetTimeDoTerminate; //时间到后线程终止end;// 在指定的画布上显示采集到的数据；procedure TCollectDataThread.ShowData;beginFCanvas.Pixels[2*FUsedTime,80+CollectData[FUsedTime]]:=clRed;end;end.3）在Form的单元文件中声明变量CollTestThread:TCollectDataThread，并在Form的OnCreate事件中加入以下代码：CollTestThread:= TCollectDataThread.Create(500,PaintBox1.Canvas);4）在“开始采集”按钮的OnClick事件中加入以下代码：CollTestThread.Resume;5）在“暂停采集”按钮的OnClick事件中加入以下代码：CollTestThread.Suspend;用户可以利用前面所提到的Synchronize函数来窗体，或者使用定时器定期刷新屏幕，这两种方式都可以间隔一定时间显示采集数据情况。

6、结束语采用上面所述的方法，笔者实现了对心电谱数据的采集和显示，达到了很好的效果。

本方法尤其适用于那些利用计算机I/O插槽来实现数据采集的硬件设备，串口通信中的采集方法也与上述思想相类似。

鉴于笔者的水平有限，欢迎读者批评指正文章中的不足之处。

合集下载

Delphi关于多线程同步的一些方法（转）

Delphi关于多线程同步的一些方法（转）

Delphi关于多线程同步的⼀些⽅法（转）线程是进程内⼀个相对独⽴的、可调度的执⾏单元。

⼀个应⽤可以有⼀个主线程，⼀个主线程可以有多个⼦线程，⼦线程还可以有⾃⼰的⼦线程，这样就构成了多线程应⽤了。

由于多个线程往往会同时访问同⼀块内存区域，频繁的访问这块区域，将会增加产⽣线程冲突的概率。

⼀旦产⽣了冲突，将会造成不可预料的结果（该公⽤区域的值是不可预料的）可见处理线程同步的必要性。

注意：本⽂中出现的所有代码都是⽤DELPHI描述的，调试环境为Windows me ，Delphi 6。

其中所涉及的Windows API函数可以从MSDN获得详细的。

⾸先引⽤⼀个实例来引出我们以下的讨论，该实例没有采取任何措施来避免线程冲突，它的主要过程为：由主线程启动两个线程对letters这个全局变量进⾏频繁的读写，然后分别把修改的结果显⽰到ListBox中。

由于没有同步这两个线程，使得线程在修改letters时产⽣了不可预料的结果。

ListBox中的每⼀⾏的字母都应该⼀致，但是上图画线处则不同，这就是线程冲突产⽣的结果。

当两个线程同时访问该共享内存时，⼀个线程还未对该内存修改完，另⼀个线程⼜对该内存进⾏了修改，由于写值的过程没有被串⾏化，这样就产⽣了⽆效的结果。

可见线程同步的重要性。

以下是本例的代码 unit.pas⽂件 unit Unit1; interface uses Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms, Dialogs, StdCtrls; //定义窗⼝类 type TForm1 = class(TForm) ListBox1: TListBox; ListBox2: TListBox; Button1: TButton; procedure Button1Click(Sender: TObject); private { Private declarations } public { Public declarations } end; //定义线程类 type TListThread=class(TThread) private Str:String; protected procedure AddToList;//将Str加⼊ListBox Procedure Execute;override; public LBox:TListBox; end; //定义变量 var Form1: TForm1; Letters:String='AAAAAAAAAAAAAAAAAAAA';//全局变量 implementation {$R *.dfm} //线程类实现部分 procedure TListThread.Execute; var I,J,K:Integer; begin for i:=0 to 50 do begin for J:=1 to 20 do for K:=1 to 1000 do//循环1000次增加产⽣冲突的⼏率 if letters[j]<'Z' then letters[j]:=succ(Letters[j]) else letters[j]:='A'; str:=letters; synchronize(addtolist);//同步访问VCL可视 end; end; procedure TListThread.AddToList; begin LBox.Items.Add(str);//将str加⼊列表框 end; //窗⼝类实现部分 procedure TForm1.Button1Click(Sender: TObject); var th1,th2:TListThread; begin Listbox1.Clear; Listbox2.Clear; th1:=tlistThread.Create(true);//创建线程1 th2:=tlistThread.Create(true);//创建线程2 th1.LBox:=listBox1; th2.LBox:=listBox2; th1.Resume;//开始执⾏ th2.Resume; end; end. 由上例可见，当多个线程同时修改⼀个公⽤变量时，会产⽣冲突，所以我们要设法防⽌它，这样我们开发的多线程应⽤才能够稳定地运⾏。

Delphi多线程编程-编程技巧文章-蓝鸟软件-15

Delphi多线程编程-编程技巧文章-蓝鸟软件-15

Delphi多线程编程-编程技巧文章-蓝鸟软件-15多线程编程(15) - 多线程同步之WaitableTimer (等待定时器对象)[续]。

本次专门研究下 SetWaitableTimer 的第二个参数(起始时间).它有正值、负值、0值三种情况, 前面已用过 0值.先学习负值(相对时间), 也就是从当前算起隔多长时间开始执行.这个相对时间是已1/100 纳秒为单位的, 譬如赋值3*10000000 相当于 3 秒.1 s(秒) = 1,000 ms(毫秒);1 s(秒) = 1,000,000 μs(微妙);1 s(秒) = 1,000,000,000 ns(纳秒);1 s(秒) = 1,000,000,000,000 ps(皮秒);本例效果图:多线程编程(15) - 多线程同步之WaitableTimer (等待定时器对象)[续]代码文件:unit Unit1;interfaceusesWindows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms,Dialogs, StdCtrls;typeTForm1 = class(TForm)Button1: TButton;procedure Button1Click(Sender: TObject);procedure FormDestroy(Sender: TObject);end;varForm1: TForm1;implementation{$R *.dfm}varf: Integer;hWaitableTimer: THandle;function MyThreadFun(p: Pointer): DWORD; stdcall;vari,y: Integer;beginInc(f);y := 20 * f;if WaitForSingleObject(hWaitableTimer, INFINITE) = WAIT_OBJECT_0 thenbeginfor i := 0 to 1000 dobeginForm1.Canvas.Lock;Form1.Canvas.TextOut(20, y, IntToStr(i));Form1.Canvas.Unlock;Sleep(1);end;end;Result := 0;end;procedure TForm1.Button1Click(Sender: TObject);varThreadID: DWORD;DueTime: Int64;beginhWaitableTimer := CreateWaitableTimer(nil, True, nil); DueTime := -3*10000000; {3秒钟后执行} SetWaitableTimer(hWaitableTimer, DueTime, 0, nil, nil, False); Repaint; f := 0;CreateThread(nil, 0, @MyThreadFun, nil, 0, ThreadID); CreateThread(nil, 0, @MyThreadFun, nil, 0, ThreadID); CreateThread(nil, 0, @MyThreadFun, nil, 0, ThreadID); end;procedure TForm1.FormDestroy(Sender: TObject);beginCloseHandle(hWaitableTimer);end;end.窗体文件:object Form1: TForm1Left = 0Top = 0Caption = 'Form1'ClientHeight = 116ClientWidth = 179Color = clBtnFaceFont.Charset = DEFAULT_CHARSETFont.Color = clWindowTextFont.Height = -11 = 'Tahoma'Font.Style = []OldCreateOrder = FalseOnDestroy = FormDestroyPixelsPerInch = 96TextHeight = 13object Button1: TButtonLeft = 96Top = 83Width = 75Height = 25Caption = 'Button1'TabOrder = 0OnClick = Button1Clickendend当我们需要一个绝对时间时, 譬如2009-2-18 13:10:5, 函数需要的 Int64 值应该是个 TFileTime 格式的时间.先看三种相关时间类型(TFileTime、TSystemTime、TDateTime)的定义:TFileTime(又名 FILETIME 或 _FILETIME)_FILETIME = recorddwLowDateTime: DWORD;dwHighDateTime: DWORD;end;TSystemTime(又名 SYSTEMTIME 或 _SYSTEMTIME)_SYSTEMTIME = recordwYear: Word;wMonth: Word;wDayOfWeek: Word;wDay: Word;wHour: Word;wMinute: Word;wSecond: Word;wMilliseconds: Word;end;TDateTime = type Double;//TFileTime 相当于一个Int64, 一般要通过给TSystemTime 或TDateTime 赋值, 然后转换过去.//在例子中我是通过下面过程转过去的:StrToDateTime -> DateTimeT oSystemTime -> SystemTimeT oFileTime -> LocalFileTimeToFileTime下面程序指定在2009年2月18号下午1点10分5秒时运行三个线程(窗体同上, 我已找了个合适的时间测试成功).unit Unit1;interfaceusesWindows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms,Dialogs, StdCtrls;typeTForm1 = class(TForm)Button1: TButton;procedure Button1Click(Sender: TObject);procedure FormDestroy(Sender: TObject);end;varForm1: TForm1;implementation{$R *.dfm}varf: Integer;hWaitableTimer: THandle;function MyThreadFun(p: Pointer): DWORD; stdcall;vari,y: Integer;beginInc(f);y := 20 * f;if WaitForSingleObject(hWaitableTimer, INFINITE) = WAIT_OBJECT_0 thenbeginfor i := 0 to 1000 dobeginForm1.Canvas.Lock;Form1.Canvas.TextOut(20, y, IntToStr(i));Form1.Canvas.Unlock;Sleep(1);end;end;Result := 0;end;procedure TForm1.Button1Click(Sender: TObject);conststrTime = '2009-2-18 13:10:5';varThreadID: DWORD;DueTime: Int64;st: TSystemTime;ft,UTC: TFileTime;dt: TDateTime;beginDateTimeToSystemTime(StrT oDateTime(strTime), st); {从TDateTime 到 TSystemTime}SystemTimeT oFileTime(st, ft);{从TSystemTime 到 TFileTime}LocalFileTimeT oFileTime(ft, UTC); {从本地时间到国际标准时间 UTC}DueTime := Int64(UTC); {函数需要的是 Int64}hWaitableTimer := CreateWaitableTimer(nil, True, nil);SetWaitableTimer(hWaitableTimer, DueTime, 0, nil, nil, False);Repaint; f := 0;CreateThread(nil, 0, @MyThreadFun, nil, 0, ThreadID);CreateThread(nil, 0, @MyThreadFun, nil, 0, ThreadID);CreateThread(nil, 0, @MyThreadFun, nil, 0, ThreadID);end;procedure TForm1.FormDestroy(Sender: TObject);beginCloseHandle(hWaitableTimer);end;end.接下来该是 WaitableTimer 对象的回调函数了。

delphi7 serversocket的多线程模式的用法

delphi7 serversocket的多线程模式的用法

delphi7 serversocket的多线程模式的用法在 Delphi 7 中，使用 ServerSocket 组件实现多线程模式可以通过以下步骤进行：1. 在 Delphi 7 的主界面上，双击 "ServerSocket" 组件，将其添加到窗体上。

2. 在 "ServerSocket1" 组件的 "Properties" 属性中，设置"Active" 属性为 True，启用服务器端。

3. 在 "ServerSocket1" 组件的 "Properties" 属性中，设置 "Port" 属性为服务器监听的端口号。

例如，设置为 1234。

4. 在 "ServerSocket1" 组件的 "Events" 事件属性中添加以下代码，实现多线程处理客户端连接请求：```procedure TForm1.ServerSocket1ClientConnect(Sender: TObject; Socket: TCustomWinSocket);begin// 创建一个线程处理客户端连接TMyThread.Create(Socket);end;```5. 创建一个继承自 TThread 的自定义线程类，用于处理客户端连接和通信。

代码示例如下：```typeTMyThread = class(TThread)privateSocket: TCustomWinSocket;publicconstructor Create(ASocket: TCustomWinSocket);procedure Execute; override;end;constructor TMyThread.Create(ASocket: TCustomWinSocket); begininherited Create(False);Socket := ASocket;end;procedure TMyThread.Execute;varBuffer: array[0..1023] of AnsiChar;BytesReceived: Integer;begin// 处理客户端连接trywhile not Terminated dobegin// 接收客户端发送的数据BytesReceived := Socket.ReceiveBuf(Buffer, SizeOf(Buffer) - 1);Buffer[BytesReceived] := #0; // 末尾添加字符串结束标志// 在主线程执行 GUI 操作（如果需要）Synchronize(procedurebegin// 在此处更新界面或执行其他需要在主线程执行的操作 // Example: Memo1.Lines.Add(Buffer);end);// 处理接收到的数据// ...end;finally// 关闭客户端连接Socket.Close;Socket.Free;end;end;```在上述代码中，TMyThread 类继承自 TThread，通过重写Execute 方法，实现在独立线程中处理客户端连接和通信的逻辑。

Delphi多线程介绍，以及线程类TThread分析

Delphi多线程介绍，以及线程类TThread分析

Delphi 多线程介绍，以及线程类TThread 分析Delphi 中有一个线程类TThread 用来实现多线程编程TThread 类的几个成员作一简单介绍，再说明一下Execute 的实现和Synchronize 的用法就完了。

然而这并不是多线程编程的全部，我写此文的目的在于对此作一个补充。

线程 本质上是进程中一段 并发 运行的代码。

一个进程至少有一个线程，即所谓的主线程。

同时还可以有多个子线程。

当一个进程中用到超过一个线程时，就是所谓的“多线程”。

1、CreateThread 、long _beginthread 、BeginThread 介绍 用Windows API 来创建线程，API 函数 CreateThread 的定义原型：1 2 3 4 5 6 7 8 HANDLE CreateThread(LPSECURITY_ATTRIBUTES lpThreadAttributes, //线程属性（用于在NT 下进行线程的安全属性设置，在9X 下无效） DWORD dwStackSize, //堆栈大小 LPTHREAD_START_ROUTINE lpStartAddress, //起始地址,即线程函数的入口，直至线程函数结束，线程结束 LPVOID lpParameter, //参数 DWORD dwCreationFlags, //创建标志（用于设置线程创建时的状态） LPDWORD lpThreadId //线程ID ); //最后返回线程HandleCreateThread 参数很多，而且在C Runtime Library 里提供了一个通用的线程函数（理论上可以在任何支持线程的OS 中使用）：1 unsigned long _beginthread(void (_USERENTRY *__start)(void *), unsigned __stksize, void *__arg);Delphi 也提供了一个相同功能的类似函数：1 f unction BeginThread(2 3 4 5 6 7 8 SecurityAttributes: Pointer;StackSize: LongWord;ThreadFunc: TThreadFunc;Parameter: Pointer;CreationFlags: LongWord;var ThreadId: LongWord): Integer;这三个函数的功能是基本相同的，它们都是将线程函数中的代码放到一个独立的线程中执行。