Thread Konzept

[MQue]

Hallo,


ich möchte von meinem Java- Programm zyklisch eine Anfrage an ein (bzw. mehrere) anderes Programm stellen, die zwei Programme sind über die serielle Schnittstelle verbunden.
Gibts da vielleicht in Design Pattern oder wie kann ich das am besten machen?
Ich habe mehrere Serielle Schnittstellen und daher auch mehrere Klassen für die einzelnen seriellen Schnittstellen.

Mir gehts nur um das Konzept: Soll ich die ganzen Anfragen in einen Thread geben oder für jede Anfrage einen Thread und wie kann ich das zeitlich machen: manche Anfragen sind alle 10s, manche alle 2s.

lg

 

[Murray]

Mach aus jeder Anfrage einen java.util.TimerTask und lass das alles vom java.util.Timer verwalten.

 

[MQue]

Puh,
kannst du mir da mehr darüber schreiben, steh momentan auf dem Holzfuß. ich würd ja quasi sowas wie unten brauchen aber das kanns ja nicht sein dasss ich 4 run- Methoden mache.
ICh hätte auch eine bessere Idee (Stichwort serialEvent) als die unten aber das ganze ist nicht auf meinem Mist gewachsen.
Vielen Dank für die Antworten

lg Michl

 public void run()
        {
        Anfrage an Computer 1 stellen
        try {
            Thread.sleep(10000);                 // 10s warten und dann wieder Anfrage stellen
            }
        catch (InterruptedException e) {}

        }

public void run()
        {
        Anfrage an Computer 2 stellen
        try {
            Thread.sleep(2000);                   // 2s warten und dann wieder Anfrage stellen und das eben zyklisch
            }
        catch (InterruptedException e) {}
        }

 

[byte]

Edit: gelöscht, da blödsinn

 

[MQue]

Hallo,

ich habe jetzt folgende Klass unten. Meine Frage wäre jetzt, ob ich für jede meiner Anfragen eine eigene Klasse benötige oder obs nur mit einer Klasse (TimerTask1) auch irgendwie geht.
this.timer1 = new Timer();
timerTask1 = new TimerTask1();
this.timer2 = new Timer();
timerTask2 = new TimerTask2();
timer1.scheduleAtFixedRate(timerTask1, 0, 2000);
timer2.scheduleAtFixedRate(timerTask2, 0, 5000);

public class TimerTask1 extends TimerTask 
    {
    private float val;
    private float ang;

    public TimerTask1() {}

    public void run() 
        {
	System.out.println("Ich soll alle 2s ausgegeben werden");
	}
}

 

[Murray]

Wenn beide Tasks das gleiche machen und der Unterschied nur in der Frequenz liegt, dann reicht selbstverständlich eine Klasse. Es reicht auf jeden Fall auch ein Timer; ein Timer kann mehrere Tasks steuern.

 

[MQue]

beide Tasks machen das gleiche nur passierend auf anderen Daten wie bei mir unten adresse, mode, start, laenge.

Kann ich der run() Methode etwas übergeben oder wie kann ich das machen, dass ich die richtigen daten in die Klasse "TimerTask1" bekomme?

Klasse 1:
timer1.scheduleAtFixedRate(timerTask1, 0, 2000);
timer1.scheduleAtFixedRate(timerTask2, 0, 5000); 

Klasse 2:
public class TimerTask1 extends TimerTask 
    {
    private byte[] anfrage1 = new byte[4];
    private byte adresse = 1;
    private byte mode    = 3;
    private byte start   = 0;
    private byte laenge  = 0;

    public TimerTask1() {}

    public void run() 
        {
        anfrage1[0] = adresse;
        anfrage1[1] = mode;
        anfrage1[2] = start;
        anfrage1[3] = laenge;     
        SerielleSchnittstelle1.writeToSPS1(anfrage1);
	}
}

 

[Murray]

Du kannst die entsprechenden Daten als Member in der Task-Klasse definieren (das hast du ja wohl schon getan) und z.B. im Konstruktor setzen.

Bsp:

public class TimerTask1 extends TimerTask {
    private byte[] anfrage1 = new byte[4];
    private byte adresse;
    private byte mode;
    private byte start;
    private byte laenge;

    public TimerTask1() { //--- ob Default-Konstruktor sinnvoll ist, hängt von der Anwendung ab
        this( 1, 3, 0, 0);
    }

    public TimerTask1( byte adresse, byte mode, byte start, byte laenge) {
        this.adresse = adresse;
        this.mode = mode;
        this.start = start;
        this.laenge = laenge;
    }

    public void run()
        {
        anfrage1[0] = adresse;
        anfrage1[1] = mode;
        anfrage1[2] = start;
        anfrage1[3] = laenge;     
        SerielleSchnittstelle1.writeToSPS1(anfrage1);
   } 
}

/* ... */

timer1.scheduleAtFixedRate( new TimerTask1( 1, 3, 0, 0), 0, 2000);
timer1.scheduleAtFixedRate( new TimerTask1( 5, 8, 2, 27), 0, 5000);

 

[MQue]

Danke, super
Eine Frage hätte ich noch: ist es definiert, wenn ich run() zur glrichen Zeit von 2 verschiedenen Tasks aufrufe, welcher als erstes ausgeführt wird?

lg
Michl