mythreadpool.pas

Delphi中处理线程池的一个组件,非常好用.

unit MyThreadPool;

interface

uses
  SysUtils, ThreadPool, MyHTTPtask;

type
  TCheckProxyPool = class(TThreadPool)
  protected
    procedure SetThread(ThreadIndex : Integer; Task : Pointer);override;
  end;

implementation

uses
  Main, Define;

{TCheckProxyPool}

procedure TCheckProxyPool.SetThread(ThreadIndex : Integer; Task : Pointer);
var
  TaskObj : PTaskObj;
begin
  with TCheckProxy(_THREADS[ThreadIndex]) do
  begin
    TaskObj := PTaskObj(Task);
    _TASK_INDEX := TaskObj^.Index;
    _USE_PROXY := True;
    _PROXY_ADDR := StrPas(PCheckProxyParam(TaskObj^.Param)^.IP);
    _PROXY_PORT := PCheckProxyParam(TaskObj^.Param)^.Port;
    _TIME_OUT := 5000;
    with frmDemo do
    begin
      _OnLvTraceLog := LvPxyTraceLog;
      _CONNET_TIME_OUT := udChkPxyTimeOut.Position*1000;
      _TARGET_URL := edtPxyChkUrl.Text;
      _SUCC_STR := edtPxySuccStr.Text;
    end;
  end;
end;


end.