TThread Execute Methode dauerhaft laufen lassen

[sk0r]

Hi,

gibt es eine Möglichkeit, dass die Methode
Execute der erbenden TThread-Klasse, wie
wenn man mit WinAPI einen Thread erstellt und
ihn dauerhaft mit einer While-Schleife laufen
lässt, dauerhaft laufen zu lassen? Der Grund ist,
ich möchte eine Winsock-Klasse erstellen und
muss dort dauerhaft die Funktion recv() aufrufen
lassen.

MfG: sk0r

[Luckie]

Du hast die Lösung doch schon selber genannt. Ja das geht.

[p0w3r5tr34m3r]

Delphi-Quellcode:

while true do begin
  // code
  recv(s, buffer, sizeof(buffer));
  // code
end;

MfG

[sirius]

Du weißt aber, dass die Sockets von Windows auch andere Möglichkeiten anbieten, als das ständige Polling. --> WSAAsyncSelect

[FAlter]

Hi,

wenn du einen Thread in einer Schleife laufen lassen willst, nimm am besten eine Bedingung mit Terminated, also repeat ... until Terminated oder so. Falls du ihn dann doch Beenden möchtest, geht es dann ganz einfach über TThread.Terminate. So lange du das nicht aufrufst, wird dein Thread weiterlaufen (Vorausgesetzt es gibt keine unbehandelten Exceptions, kein break und kein exit in deinem Code).

Mfg
FAlter

[sk0r]

Naja, das Problem ist, wenn ich

Delphi-Quellcode:

procedure Thread.Execute;
begin
  while true do
  begin  
    //Irgendwas machen
    Sleep(10);
  end;
end;

benutze, dann wird meine Hauptanwendung blockiert. :/

Delphi-Quellcode:

unit Unit1;

interface

uses
  Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms,
  Dialogs, StdCtrls;

type
  TForm1 = class(TForm)
    Button1: TButton;
    procedure FormCreate(Sender: TObject);
    procedure Button1Click(Sender: TObject);
  private
    { Private-Deklarationen }
  public
    { Public-Deklarationen }
  end;

  thread = class(TThread)
    procedure Execute;
  end;

var
  Form1: TForm1;
  gthread: thread;

implementation

{$R *.dfm}

procedure thread.Execute;
begin
  while true do
  begin
    ShowMEssage('TEST');
    Sleep(10);
  end;
end;

procedure TForm1.FormCreate(Sender: TObject);
begin
  gthread := thread.Create(true); 
end;

procedure TForm1.Button1Click(Sender: TObject);
begin
  gthread.Execute;
end;

end.

[FAlter]

Hi,

du darfst nicht direkt die Execute aufrufen. Stattdessen musst du den Thread mit Resume starten (oder du übergibst gleich false an den Thread, dann wird er sofort gestartet).

Und ich glaube, ShowMessage aus dem Thread aufzurufen fällt in die Kategorie, in welcher Synchronize angesagt ist. Nimm lieber eine MessageBox.

Mfg
FAlter

[sirius]

ein "override" wäre in der Deklaration der Methode execute noch sehr hilfreich.

[sk0r]

Ok, bei Resume bekomme ich nun einen abstrakten Error. ó_Ò

Kann jemand mal meinen Code ansehen? Wäre echt nett.

Delphi-Quellcode:

unit sockettest;

interface

uses
  SysUtils,
  Classes,
  Windows,
  Winsock;

type
  TSockThread = class(TThread)
    iSock: Cardinal;
    recvProc: procedure(szString: String);
    procedure Execute;
  end;

  TSmallSock = class
      constructor Create(Address: PChar; Port: Cardinal);
      procedure Free;
    private
      lpAddress: PChar;
      dwPort: Cardinal;
      iSock: Cardinal;
      WSAData: TWSAData;
      addrIn: TSockAddrIn;
      dwThreadID: Cardinal;
      gThread: TSockThread;
    public
      procRecv: procedure(szString: String);
      function DoConnect:Boolean;
      function SendString(szString: String):Boolean;
  end;


var gSmallSock: TSmallSock;

implementation

procedure TSockThread.Execute;
var
  mBuf: array[0..1000-1] of Char;
begin
  if recv(gSmallSock.iSock, mBuf, sizeof(mBuf), 0) <> SOCKET_ERROR then
  begin
    if mBuf <> '' then
    begin
      recvProc(mBuf);
      mBuf := '';
    end;
  end;
end;

constructor TSmallSock.Create(Address: PChar; Port: Cardinal);
begin
  lpAddress := Address;
  dwPort := Port;
end;

function TSmallSock.DoConnect:Boolean;
begin
  result := false;
  try
    if WSAStartup(MAKEWORD(2, 2), WSAData) <> SOCKET_ERROR then  
    begin
      iSock := socket(AF_INET, SOCK_STREAM, 0);
      if iSock = SOCKET_ERROR then exit;

      addrIn.sin_family := AF_INET;
      addrIn.sin_port := htons(dwPort);
      addrIn.sin_addr.S_addr := inet_addr(lpAddress);

      if connect(iSock, addrIn, sizeof(addrIn)) <> SOCKET_ERROR then 
      begin
        gThread := TSockThread.Create(true);
        gThread.iSock := iSock;
        gThread.recvProc := procRecv;
        gThread.Resume;

        result := true;
      end;
    end;
  except
    WSACleanup; 
  end;
end;

function TSmallSock.SendString(szString: String):Boolean;
begin
  result := false;

  if send(iSock, szString, length(szString), 0) <> SOCKET_ERROR then
    result := true;
end;

procedure TSmallSock.Free;
begin
  inherited Free;

  gThread.DoTerminate;
  WSACleanup;
end;

end.

[sirius]

Zitat von sk0r:

Ok, bei Resume bekomme ich nun einen abstrakten Error. ó_Ò

Siehe Post #8