TThread Execute Methode dauerhaft laufen lassen

[FAlter]

Hi,

Die Lösung steht hier:

Zitat von sirius:

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

Mfg
FAlter

[edit] Mal wieder kein roter Kasten. Sonst habe wenigstens ich immer Glück. [/edit]

[sk0r]

Ok, danke für eure Hilfe. Hab ich wohl eine Sache der Grundkenntnisse vergessen. :/

[Muetze1]

... und deine Procedure "Free" kannst du auch gleich mal in die Tonne drücken und als Destructor Destroy; override; gleich mal neu auferstehen lassen...

[Luckie]

Hier: http://delphitutorials.michael-puff.de gibt es auch ein entsprechendes Tutorial.

[sirius]

Noch etwas:
Du greifst in deinem Thread auf eine globale Variable zu (gSmallSock.iSock). Du hast doch dein Sockethandle bereits innerhalb deines Threadobjektes. Das kannst du doch benutzen.
Die Procedure "recvProc" muss Threadsafe sein oder du musst vorher synchronisieren.

[sk0r]

Darf ich fragen, was Du mit Threadsafe genau meinst?^^

[sirius]

Du darfst in einer Funktion/Unit/Klasse/etc. , die du ThreadSafe haben möchtest, niemals auf Variablen oder Speicher zugreifen, die auch ausserhalb dieses Objektes genutzt werden (oder du musst synchronisieren).
Für dich bedeutet dass, dass du in RecvProc nur lokale Variablen verwenden darfst und vor allem keine GUI.

[sk0r]

Und wie kann ich es machen, damit ich auf globale Variablen/Speicher zugreifen darf, ohne Fehler zu verursachen?
Weil, irgendwie muss es ja gehen, die TClientSocket Komponente arbeitet doch auch mit Threads!?

[sirius]

Delphi-Quellcode:

type 
  TSockThread = class(TThread) 
    iSock: Cardinal; 
    recvProc: procedure(szString: String);  
    procedure Execute; override;
  protected
    FBuffer:string;
    procedure CallRecvProc; 
  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.CallRecvProc; 
begin
  recvProc(FBuffer);      
end;
procedure TSockThread.Execute; 
var 
  mBuf: array[0..1000-1] of Char; 
begin 
  if recv(iSock, mBuf, sizeof(mBuf), 0) <> SOCKET_ERROR then 
  begin 
    if mBuf <> '' then 
    begin 
      FBuffer:=mBuf;
      synchronize(CallRecvProc);
      mBuf := ''; 
    end; 
  end; 
end;

[sk0r]

Ok, eine Frage habe ich noch. :/

Wenn ich TClientSocket benutze und es kommen Daten rein, dann bleibt das Programm
"hängen", bis TClientSocket.OnRecieve ausgeführt wurde. Wie kann ich das realisieren?
Weil im Moment wird es ja "gleichzeitig" ausgeführt. Ich hoffe, ihr wisst, was ich meine. :/