Timer bzw. TimerTask Frage

[skywalker]

hallo leute,

folgende frage:

ich habe 3 klassen (server, link, client) die miteinander verbunden sind und nachrichten austauschen:

server --> link --> client bzw. client --> link --> server

also die server-klasse sendet über die link-klasse dem client kontinuierlich nachrichten.
auch der client sendet dem server kontinuierlich nachrichten.
das kontinuierliche ist jeweils gelöst über einen TimerTask der in der server bzw. client klasse im constructor aufgerufen wird, also quasi automtisiert läuft.

die send methode, also das eigentliche senden bzw. weiterleiten der nachricht ist in der link klasse implementiert - ich möchte nun das senden der nachricht in der link klasse verzögern (um einen fixen wert ) - kann aber nicht thread.sleep() verwenden da es mehrere server und noch mehr clients gibt und bei sleep() ja das ganze programm wartet (meines bescheidenen wissens nach - oder?) also alles steht. (und die link klasse kann ich auch nicht mehr extendn da sie schon extendet ist)

hat wer eine idee wie ich die verzögerung des sendens der nachricht über timer bzw. timertask lösen kann?

 

[hdi]

Ich verstehe nicht ganz, du hast x server, y clients und 1 Link? Hat nicht jeder Server und jeder Client seinen eigenen Link?

 

[skywalker]

ja, jede verbindung server-client hat einen eigenen link.

einfachheitshalber gibts einstweilen nur einen server und 10 clients. also 1 server schickt über 10 verschiedene links an 10 verschiedene clients.

 

[skywalker]

hallo allerseits,

bin ein bei meinem problem ein wenig weitergekommen und versuch das mit einem timer task zu lösen.

mein problem - ich weiss nicht wie ich die send methode in den WaitTask bekomme und mir dabei nodeFrom und msg merke... - also im endeffekt will ich das senden was mithilfe der send methode passiert um eine bestimmte zeit (delay) verzögern...

import java.util.Timer;
import java.util.TimerTask;

public class ConnectorWithFixedDelay extends Connector {

  private long delay;
  Timer timer = new Timer();

  public ConnectorWithFixedDelay(long delay){
    this.delay = delay;
  }
  
  public void send(Node nodeFrom, Message msg){  
    
    if(nodeFrom == nodeLeft) {
        this.fixedDelay();
        nodeRight.send(this, msg);         
    } else if(nodeFrom == nodeRight) {        
        this.fixedDelay();
        nodeLeft.send(this, msg);      
      }
  }
  
  private void fixedDelay(){
    timer.schedule(new WaitTask(), delay);        
  }

  class WaitTask extends TimerTask {    
    public void run() { 
      System.out.println("verögerung beendet");// test output
      WIE BEKOMM ICH DAS SENDEN HIER REIN???
      timer.cancel();
    }
  }
}

noch anzumerken vielleicht - das senden stellt lediglich eine weiterleitung dar... also nodeFrom sendet eine message die dann entweder (in abhängigkeit von wo die nachricht kommt - also vom linken knoten oder rechten knoten) an den linken oder rechten knoten weitergeleitet wird - das ganze soll eben verzögert werden...

 

[Murray]

Mach alles, was du in der Operation brauchst ( Node,Message,ConnectorWithFixedDelay) zu Membern der Klasse WaitTask und initialisiere alles im WaitTask-Konstruktor aus entsprechenden Parametern.

 

[skywalker]

checks nicht ganz wie ich das programmtechnisch umsetzen kann... :autsch:

 

[Murray]

import java.util.Timer;
import java.util.TimerTask;

public class ConnectorWithFixedDelay extends Connector {

  private long delay;
  Timer timer = new Timer();

  public ConnectorWithFixedDelay(long delay){
    this.delay = delay;
  }
 
  public void send(Node nodeFrom, Message msg){ 
   
    if(nodeFrom == nodeLeft) {
        this.fixedDelay( nodeRight, msg);
    } else if(nodeFrom == nodeRight) {       
        this.fixedDelay( nodeLeft, smg);
      }
  }
 
  private void fixedDelay(  Node nodeFrom, Message msg){
    timer.schedule(new WaitTask( this, nodeFrom, msg), delay);       
  }

  class WaitTask extends TimerTask {

    ConnectorWithFixedDelay conn;
    Node nodeFrom;
    Message msg
   
    public WaitTask(  ConnectorWithFixedDelay conn, Node nodeFrom, Message msg) {
      this.conn = conn;
      this.nodeFrom = nodeFrom;
      this.msg = msg;
    }

    public void run() {
       System.out.println("Verzögerung beendet");// test output
       nodeFrom.send( conn, msg);
    }
  }
}

 

[skywalker]

:applaus: ein grosses dankeschön murray!!!