[delphi] Gegevens terugsturen: Class <-- Class

[Possstema]

Ik heb een probleem. Ik heb een classe waarin een thread-classe wordt gecreate. En de thread controleerd een TCP-client op inkomende berichten van een server. Nu heeft de classe een verwerk( bericht ) functie alleen nu krijg ik het niet voormekaar om de thread.execute een functie te laten aanroepen uit de classe waarin hij zelf is gemaakt.

Wat ik al heb geprobeerd: Ik gaf een pointer mee van de hooftclasse bij het createn van de thread en die pointer dan gebruiken als pointer.verwerk( bericht ) in de thread.execute. Maar dat vindt delphi niet goed. Heeft iemand een idee hoe ik dit ( netjes ) kan oplossen?

[NMe]

Misschien leuk als je erbij vertelt wat Delphi niet leuk vindt aan jouw oplossing. Zo blijft het een beetje raadwerk.

[Robbemans]

Voeg aan je thread object een event property toe, bijvoorbeeld een TNottification.
In je hoofdklasse maak je een procedure met een gelijke parameterlijst als je event property.

instantieer je thread suspended en vul de property in je thread met de waarde van je procedure in je hoofdklasse.

Nu kun je (eventueel synchronized) je event aanroepen en zal de code in je hoofdklasse worden uitgevoerd.

[Possstema]

De error die ik krijg is: System error 1400 ongeldige vensteringang

Edit @ Robbemans: Pfwiew, daar snap ik niet zo veel van, k zal me even verdiepen in property's.

Om wat te verduidelijken:

Delphi:

  TRecThread = class( TThread )
    private
      client : TIdTCPClient;
      ChatP : pointer;
    public
      constructor create( client : TIdTCPClient; ChatP : pointer );
      procedure execute; override;
  end;

  TChatP = class( TObject )
    private
      client : TIdTCPClient;
      username : string;
      password : string;
      host : string;
      port : integer;
      transaction_id : integer;
      rec_thread : TRecThread;
    public
      log : TStrings;
      constructor create( client : TIdTCPClient; username, password, host : string; port : integer );
      function tr_id : string;
      function connect : boolean;
      procedure disconnect;
      procedure process_msg( msg : string );
      procedure send( msg : string );
  end;

[ Voor 89% gewijzigd door Possstema op 06-05-2006 22:35 ]

[Robbemans]

Om mezelf dan maar wat wat te verduidelijken, effe uit het hoofd:

Delphi:

  TRecThread = class( TThread )
    private
      client : TIdTCPClient;
      FThreadNotify: TNotification;
    public
      constructor create(Suspended: Boolean)
      procedure execute; override;
      property ThreadNotify: TNotification read FThreadNotify write FThreadNotify 
  end;

  TChatP = class( TObject )
    private
      client : TIdTCPClient;
      username : string;
      password : string;
      host : string;
      port : integer;
      transaction_id : integer;
      rec_thread : TRecThread;
      procedure ChatThreadNotify(Sender: TObject);
    public
      log : TStrings;
      constructor create( client : TIdTCPClient; username, password, host : string; port : integer );
      function tr_id : string;
      function connect : boolean;
      procedure disconnect;
      procedure process_msg( msg : string );
      procedure send( msg : string );
  end;


...

implementation


constructor TChatP.Create(...)
begin
  rec_thread := TRecThread.Create(True);
  rec_thread.ThreadNotify := ChatThreadNotify; // Gebruik ThreadNotify in je thread om ChatThreadNotify aan te roepen
  rec_thread.Resume;
end;

[ Voor 28% gewijzigd door Robbemans op 06-05-2006 22:52 ]

[Possstema]

Hmm, k kom er niet echt uit, hij kent TNotification niet. Ik zal nog eens nadenken of ik het ook anders kan oplossen.

Edit: Moet TNotification ook TNotifyEvent zijn?

Edit2: Hmm, het werkt als ChatThreadNotify(Sender: TObject); gebruik, alleen hoe kan ik nou eits meegeven ( zoals een string ) ChatThreadNotify( msg : string ); mag niet.

[ Voor 53% gewijzigd door Possstema op 07-05-2006 00:54 ]

[Possstema]

Ik heb het , en het werkt ook nog . Ik roep dus die ThreadNotify( self ) aan waarmee in de ChatThreadNotify een process_msg(TRecThread(Sender).msg); staat ( of was dat ook de bedoeling ). iig hartelijk bedankt. Als ik klaar met het project ben zal ik de source posten .

[LordLarry]

Je moet nog wel je best doen om die code thread safe te maken. Bijvoorbeeld met Synchronize. Zie http://www.nldelphi.com/c...s.exe/?Category=Threading

[Possstema]

LordLarry schreef op zondag 07 mei 2006 @ 10:45:
Je moet nog wel je best doen om die code thread safe te maken. Bijvoorbeeld met Synchronize. Zie http://www.nldelphi.com/c...s.exe/?Category=Threading

Zoiets dus:

Delphi:

procedure TRecThread.SyncedProc;
begin
  repeat
    msg := client.ReadLn(); // Try to read a message send from the server
    ThreadNotify( self );   // Sends the message to the TChatP Class to process
  until terminated;
end;

procedure TRecThread.execute;
begin
  Synchronize( SyncedProc );
end;

Dan werkt het wel, maar als de TCP server dan stopt met zenden dan hangt het programma ook.

[LordLarry]

Erm, nee. Zoiets dus:

Delphi:

procedure TRecThread.SyncedProc;
begin
  ThreadNotify( self );   // Sends the message to the TChatP Class to process
end;

procedure TRecThread.execute;
begin
  repeat
    msg := client.ReadLn(); // Try to read a message send from the server
    Synchronize( SyncedProc );
   until terminated;
end;

[Possstema]

helemaal top, t werkt nu perfect, Bedankt !!