Timer / Thread

[MrZylinder]

Hallo Forum,

ich stehe mal wieder vor einem Problem.

Ich hab eine Textdatei die lese ich aus und geb sie in einem JFrame der ein JTextArea enthält aus.

Folgendes steht in meinem Hauptprogramm:

try {
		String pfad = JOptionPane.showInputDialog(frame,"Pfad zur status.dat: ");
		BufferedReader br = new BufferedReader(new FileReader(pfad));
		
		String lesen = br.readLine();
		list1 = new ArrayList<String>();
		sb = new StringBuilder();
		
		int anzahlStatus = 0;
		
		String hosts = JOptionPane.showInputDialog(frame,"Wie viel Hosts werden benutzt: ");
		int eingabeAnzahl = Integer.parseInt(hosts);
		
		PopUpTest2 db = new PopUpTest2();
		
			//Es wird nach hostname und currentstate gesucht und in die ArrayList eingetragen
			while((lesen = br.readLine()) != null && anzahlStatus < eingabeAnzahl) 
			{
				if(lesen.contains("host_name="))
				{
					list1.add(lesen);
				}	
				if(lesen.contains("current_state="))
				{
					anzahlStatus++;
				}
				if(lesen.contains("current_state=0"))
				{
					list1.add(", OK");
					list1.add("\r\n");
				
				}
				if(lesen.contains("current_state=1"))
				{
					list1.add(", WARNING");
					list1.add("\r\n");
				}
				if(lesen.contains("current_state=2"))
				{
					list1.add(", CRITICAL");
					list1.add("\r\n");
				}
				if(lesen.contains("current_state=3"))
				{
					list1.add(", UNKNOWN");
					list1.add("\r\n");
				}
			}
			
		
			
			for(int i=0;i<list1.size();i++)
			{
				ta.append(list1.get(i));
			}
						
		} 
	catch (FileNotFoundException e) 
	{
			JOptionPane.showMessageDialog(frame,"Datei wurde nicht gefunden!");
	}

Und dies is mein Frame:

public PopUpTest2() {
	frame = new JFrame ("IcingaInfo");
	ta = new JTextArea();	
	frame.setSize(400, 400);
	frame.setVisible(true);
	frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
	frame.add(ta);
	ta.setEditable(false);	
	}

Ich hab jetzt folgende Fragen (ich hab zwar die API gelesen, aber irgendwie versteh ich das alles nicht so ganz):

1. Was soll ich in meinem Fall benutzen: Timer oder Thread?
2. Wie mache ich denn meine Schleife bzw. mein Hauptprogramm zu einem Thread bzw. verpacke es mit einer Schleife?

Ich hoffe mir kann jemand helfen. Vielen Dank schon mal im Voraus!

 

[mrbela]

Hey,

warum willst Du das Auslesen in einen extra Thread packen? Das JFrame soll doch sicher erst geladen werden, bzw. angezeigt werden, wenn die Textdatei komplett ausgelesen ist, oder?

Dein Hauptprogramm läuft doch schon innem Thread. Das musst Du also nicht noch extra als Thread machen.

Aber so richtig verstehe ich noch nicht, was Du meinst..

 

[MrZylinder]

also ich möchste das ich mein Frame geöffnet lassen kann und es sich alle sagen wir mal 60sek. aktualisiert.

 

[mrbela]

Mh, okay.. Ändert sich denn der Inhalt der Textdatei in dieser Zeit? Sonst würde es ja keinen Sinn machen, die Datei alle 60sec auszulesen..

 

[Volvagia]

1) Würde Timer vorziehen, Threads gehen auch, sind aber imho besser wenn etwas für jeden Durchgang zusätzlich gespeichern werden muss (um Methodenvariablen statt Felder zu nutzen).
2) Indem du eine Schleife drum herum packst ???:L Das "Hauptprogramm" verstehe ich nicht, das ist zu abstrakt. Sobald du die Schleife startest und sie ein Nicht-Dämon ist ist sie ja quasi das Hauptprogramm.

Prüf auch ob deine JFrame im EDT erzeugt wird, und setVisible sollte man erst aufrufen nach dem die GUI fertig gebaut wurde.

 

[MrZylinder]

Hört sich jetzt blöd an aber:

Kann sich ändern muss sich aber nicht ändern.

Es geht um ein Programm das ich schreibe für das Monitoring-Tool Icinga. Das schaut im Netzwerk ob alles in ordnung ist. Z.B. Ping oder so.

Also es kann sein das sich eine Woche lang nix ändert an dem Status. Kann aber auch sein das es sich jede Minute ändert.

 

[mrbela]

Allein aus Performance-Gründen würde sich ein Flag lohnen, ob die Datei sich geändert hat (also ob ein anderer Teil des Programms reingeschrieben hat oder nicht). Falls true -> neu auslesen. Falls false kannst Du die Ausgabe ja so lassen.

 

[MrZylinder]

Also ich muss dazu sagen ich kenne mich mit dieser materie noch garnicht aus. Wie kann ich so ein Flag realisieren. Kannst du mir vielleicht ein Codebeispiel bringen?

 

[Attila]

// in main thread:
ScheduledExecutorService executor=Executors.newScheduledThreadPool(1);
executor.scheduleWithFixedDelay(new Runnable(){
    public void run() {
        // Daten auslesen
        // ...
        // JTextArea aktualisieren:
        SwingUtilities.invokeLater(new Runnable(){
            public void run() {
                // ta.append(.......);
            }
        });
    }
},1, 60, TimeUnit.SECONDS);

 

[mrbela]

Also ich muss dazu sagen ich kenne mich mit dieser materie noch garnicht aus. Wie kann ich so ein Flag realisieren. Kannst du mir vielleicht ein Codebeispiel bringen?

Ein Flag lässt sich am besten mit einem boolean (true/false) realisieren. Wenn Du die Datei änderst, setzt Du dieses boolean auf true. Wenn die Routine, die prüft, ob sich was geändert hat und falls ja die JTextArea updatet, durchgelaufen ist, also alles auf dme neusten Stand ist, setzt Du dieses Flag wieder auf false.

boolean flag = false
flag = true;

// usw.

 

[Volvagia]

Das funktioniert aber nur, sofern dein Programm auch erfährt, dass die Datei geändert wurde oder dieses Icinga nicht selbstständig ändert.

@Attila: append ist Thread-Safe.

 

[MrZylinder]

Also dieses Icinga ändert die Datei selbstständig sobald etwas mit dem Host nicht stimmt....

 

[MrZylinder]

Was ich halt nicht verstehe...Warum muss ich in dem 1. run() meine ganzen Variablen auf Final setzen.
Und wenn ich das gemacht habe muss ich noch ein try catch einbauen weil ich ja im ersten run meine datei auslese. Aber das funktioniert nicht

 

[Michael...]

Was ich halt nicht verstehe...Warum muss ich in dem 1. run() meine ganzen Variablen auf Final setzen.

Ohne Code schwer zu sagen. Liegt aber wohl am Gültigkeitsbereich der Variablen. Vermutlich versuchst in einer inneren Klasse auf ein lokale Variablen zu zugreifen, dass geht dann natürlich nur wenn diese final sind - ist aber wie gesagt nur eine Vermutung.

Und wenn ich das gemacht habe muss ich noch ein try catch einbauen weil ich ja im ersten run meine datei auslese. Aber das funktioniert nicht

Zugriffe auf's Dateisystem müssen nunmal mittels try catch abgesichert werden. Warum was nicht funktioniert? Liegt vermutlich am Code denn ich hier nicht sehe ;-)

 

[MrZylinder]

public void run() {
		    	try{
		    	while((lesen = br.readLine()) != null && anzahlStatus < eingabeAnzahl) 
				{
					if(lesen.contains("host_name="))
					{
						list1.add(lesen);
					}	
					if(lesen.contains("current_state="))
					{
						anzahlStatus++;
					}
					if(lesen.contains("current_state=0"))
					{
						list1.add(", OK");
						list1.add("\r\n");
					
					}
					if(lesen.contains("current_state=1"))
					{
						list1.add(", WARNING");
						list1.add("\r\n");
					}
					if(lesen.contains("current_state=2"))
					{
						list1.add(", CRITICAL");
						list1.add("\r\n");
					}
					if(lesen.contains("current_state=3"))
					{
						list1.add(", UNKNOWN");
						list1.add("\r\n");
					}
				}
		    	}
		    	catch{
		    		
		    	}
		    	}
		        SwingUtilities.invokeLater(new Runnable(){
		            public void run() {
		            	for(int i=0;i<list1.size();i++)
		    			{
		    				ta.append(list1.get(i));
		    			}
		    			
		            }
		        });
		    }
		},1, 60, TimeUnit.SECONDS);

Das wäre der code wie ich es vor hatte
Folgende Fehlermeldungen kommen: Syntax error on tokens, AnnotationName expected instead (bei swing.utilities...)
Multiple markers at this line
- Syntax error, insert "enum Identifier" to complete
EnumHeaderName(bei })
Syntax error on token "catch", finally expected (bei catch)
Syntax error on token "}", delete this token (bei ,1, 60, TimeUnit.SECONDS)
Manche Fehlermeldungen sind mir ja schon klar wie zum beispiel die letzte, aber wie ich es wende und drehe bekomm ich es einfach nicht ohne fehler hin

 

[Volvagia]

Schau dir mal das catch an und dann zähl die Klammern wo SwingUtilities steht.
Und dann schreib was in die Klammern des catches rein. Lässt der Builder leider leer durchgehen, sollte er aber nicht. :noe:

 

[Michael...]

Der Code ist ja auch syntaktisch völlig daneben. Da stimmen einige Klammern wohl nicht.
Ein try catch Block schaut folgendermaßen aus

try {
} catch (Exception exc) {
    //catch Blöcke lässt man niemals leer, wie will man sonst den Fehler ermitteln wenn man keine Infos bekommt.
    exc.printStackTrace();
}

... und ein final sehe ich hier nirgends.

 

[MrZylinder]

Die variablen hab ich vorher auf final gesetzt.
Ein Problem hab ich noch: bei der Variable lesen und anzahlStatus da kommt folgende fehlermeldung:
The final local variable lesen cannot be assigned, since it is defined in an enclosing type
wie kann ich diese behandeln

 

[Volvagia]

Du kannst eine Konstante nicht verändern, denn das ist der Sinn einer Konstante.
Du könntest die Variable in ne Konstante umkopieren.

final int constantAnzahlStatus = anzahlStatus;

 

[Michael...]

Die variablen hab ich vorher auf final gesetzt.
Ein Problem hab ich noch: bei der Variable lesen und anzahlStatus da kommt folgende fehlermeldung:
The final local variable lesen cannot be assigned, since it is defined in an enclosing type
wie kann ich diese behandeln

Hört sich nach einem Grundlagenproblem an. Der Geltungsbereich von Variablen sollte so klein wie möglich und so weit wie nötig gehalten werden.
Der Sinn und Zweck einer finalen Variable ist, dass man dieser keinen neuen Wert zuweisen kann. Ist für Deinen Zweck wohl ein bisschen ungünstig, dann schließlich erhalten die zwei ja in der Schleife ständig neue Zuweisungen. Allerdings werden die beiden Variablen auch nur im Kontext der Schleife benötigt => mögliche Lösung: Die beiden Variablen innerhalb der run() oder sogar innerhalb des try Abschnitts deklarieren.

 

[MrZylinder]

Hm grundlagen sind eigentlich klar. Aber ich mache das alles nicht so oft und somit fällt mir vieles erst dann wieder ein wenn es mir jmd sagt xD.. ich teste es mal mit der deklaration innerhalb von run ^^

 

[Volvagia]

Warum nicht?
Lies dir mal die Antwort von Michael durch, denke die kannst du übersehen haben: http://www.java-forum.org/956509-post20.html

Warum eigendlich final? Wenn du sie als Instanzenfeld deklarierst (was du offensichtlich tust) kannst du sowohl von allen anonymen und nichtstatischen nested Klassen darauf zugreifen.

 

[Michael...]

Habs jetzt getestet wie du gesagt hast. Ging aber trotzdem nicht. =/

Mein Beleid, viel mehr kann man dazu nicht sagen ;-)

 

[MrZylinder]

Ja hab ich überlesen Sorry.
Soweit funktioniert es jetzt mal muss jetzt nur mal bissjen rumtesten danke ^^

 

[MrZylinder]

Hab jetzt noch 2 fragen:

1. Warum langt bei diesem code kein Try Catch. Es zeigt mir an das ich noch ein Finally dazu machen muss:

		executor.scheduleWithFixedDelay(new Runnable(){
		    public void run()  {
		    	try {
		    		
		    		BufferedReader br = new BufferedReader(new FileReader(pfad));
		    		int anzahlStatus = 0;
		    		String lesen = br.readLine();
		    	
		    	
		    	while((lesen = br.readLine()) != null && anzahlStatus < eingabeAnzahl) 
				{
					if(lesen.contains("host_name="))
					{
						list1.add(lesen);
					}	
					if(lesen.contains("current_state="))
					{
						anzahlStatus++;
					}
					if(lesen.contains("current_state=0"))
					{
						list1.add(", OK");
						list1.add("\r\n");
					
					}
					if(lesen.contains("current_state=1"))
					{
						list1.add(", WARNING");
						list1.add("\r\n");
					}
					if(lesen.contains("current_state=2"))
					{
						list1.add(", CRITICAL");
						list1.add("\r\n");
					}
					if(lesen.contains("current_state=3"))
					{
						list1.add(", UNKNOWN");
						list1.add("\r\n");
					}
				}
		    	}
		    	catch (FileNotFoundException e) 
		    	{
		    			JOptionPane.showMessageDialog(frame,"Datei wurde nicht gefunden!");
		    	} catch (IOException e) {
					
					e.printStackTrace();
				}
		    	
		        SwingUtilities.invokeLater(new Runnable(){
		            public void run() {
		            	for(int i=0;i<list1.size();i++)
		    			{
		    				ta.append(list1.get(i));
		    			}
		    			
		            }
		        });
		    }
		},0, 10, TimeUnit.SECONDS);
	} 
	[WR]finally {
		
	}[/WR]

2. Es wird jetzt Testweise alle 10 sek aktualisiert. Aber es bleibt dann nicht bei einer TextArea sonder mein Programm hängt einfach das aktualisuerte unten dran...Weis jemand wie ich das lösen kann?

 

[Michael...]

Hab jetzt noch 2 fragen:

1. Warum langt bei diesem code kein Try Catch. Es zeigt mir an das ich noch ein Finally dazu machen muss:

	executor.scheduleWithFixedDelay(new Runnable(){
		public void run()  {
			try {
				BufferedReader br = new BufferedReader(new FileReader(pfad));
				...		    	
				while((lesen = br.readLine()) != null && anzahlStatus < eingabeAnzahl) {
					...
				}
			}
			catch (FileNotFoundException e) {
				...
			} catch (IOException e) {		
				...
			}
			SwingUtilities.invokeLater(new Runnable(){
				...
			});				
		}
	},0, 10, TimeUnit.SECONDS);
	} 
	finally {
		
	}

Wenn man den Code sauber strukturiert und genauer betrachtet, stellt man fest, dass das finally nicht zu der try catch in der run Methode gehört. Woher die Forderung nach einem finally kommt, kann man daher nicht sagen.

2. Es wird jetzt Testweise alle 10 sek aktualisiert. Aber es bleibt dann nicht bei einer TextArea sonder mein Programm hängt einfach das aktualisuerte unten dran...Weis jemand wie ich das lösen kann?

In dem geposteten Code wird die TextArea nicht zurückgesetzt, sondern immern nur mit append neuer Inhalt angefügt.

 

[MrZylinder]

Ehm...im Forum hab ich gefunden das ich es zum Beispiel mit ta.setText(""); machen kann aber irgendwie klappt das nicht...gibts noch andere möglichkeiten. Vielleich hab ich es auch falsch eingefügt ... dieses ta.setText(""); muss doch nach dem 2. run() hin oder?

 

[Michael...]

Was ist der 2. run()? Kann man nicht grundsätzlich vor dem Neubefüllen

setText("")

an de r Textarea aufrufen?

 

[MrZylinder]

Das is ja mein Problem ich hab jetzt mal bevor sie gefüllt wird auf setText(""); gemacht..aber es wird trotzdem angefügt un nicht resettet.

 

[Michael...]

setText() setzt den Text an der Komponente an der die Methode aufgerufen wurde - dafür existiert sie ja. Und setText("") leert somit die Textkomponente. Was da bei Dir nicht funktioniert, kann man so nicht sagen.
Wenn ich das "bleibt dann nicht bei einer TextArea" aus dem alten Post lese: Erzeugst Du jedesmal eine neue JTextArea?

 

[MrZylinder]

Nein also es bleibt im Prinzip bei einer Area, hab extra geschaut es wird nur eine erzeugt. Aber die neuen einträge werden zusätzlich noch eingefügt.

 

[Michael...]

Dann ist irgendwas anderes in Deinem Code falsch.

 

[MrZylinder]

Ach nee xDDDDDD

 

[Michael...]

War ein Hinweis: Ohne den Code zu kennen, kann man nicht sagen wo der Fehler steckt.

 

[MrZylinder]

Ich hab doch mein Code reingestellt

Kann es vllt sein das nur das

public void run() {
		            	for(int i=0;i<list1.size();i++)
		    			{
		    				ta.append(list1.get(i));
		    			}

nach 10 sek ausgeführt wird oder das ganze?

 

[Michael...]

Ich hab doch mein Code reingestellt

Da wird aber nirgends

setText("")

verwendet.

 

[MrZylinder]

Oh ich bitte um entschuldigung... moment das hab ich total verpeilt:

 public void run()  {
		    	try {
		    		ta.setText(null);
		    		ta.repaint();
		    		BufferedReader br = new BufferedReader(new FileReader(pfad));
		    		int anzahlStatus = 0;
		    		String lesen = br.readLine();
		    		
		    		while((lesen = br.readLine()) != null && anzahlStatus < eingabeAnzahl) 
		    		{
		    			if(lesen.contains("host_name="))
		    			{
		    				list1.add(lesen);
		    			}	
		    			if(lesen.contains("current_state="))
		    			{
		    				anzahlStatus++;
		    			}
		    			if(lesen.contains("current_state=0"))
		    			{
		    				list1.add(", OK");
		    				list1.add("\r\n");
					
		    			}
		    			if(lesen.contains("current_state=1"))
		    			{
		    				list1.add(", WARNING");
		    				list1.add("\r\n");
		    			}
		    			if(lesen.contains("current_state=2"))
		    			{
		    				list1.add(", CRITICAL");
		    				list1.add("\r\n");
		    			}
		    			if(lesen.contains("current_state=3"))
		    			{
		    				list1.add(", UNKNOWN");
		    				list1.add("\r\n");
		    			}
					}
		    	}
		    	catch (FileNotFoundException e) 
		    	{
		    			JOptionPane.showMessageDialog(frame,"Datei wurde nicht gefunden!");
		    	} 
		    	catch (IOException e) 
		    	{
					
					e.printStackTrace();
				}
		    	
		        SwingUtilities.invokeLater(new Runnable(){
		            public void run() {
		            	for(int i=0;i<list1.size();i++)
		    			{
		    				ta.append(list1.get(i));
		    			}
		    			
		            }
		        });
		    }
		},0, 10, TimeUnit.SECONDS);
	}

 

[Michael...]

Mal abgesehen davon, dass man sich das ta.repaint sparen kann und ta.setText mit in der run() des invokeLaters - also auch auf dem EDT - ausgeführt werden sollte, sehe ich auf Anhieb keine weiteren Fehler in dem Codeabschnitt.

 

[MrZylinder]

Wenn ichs in das run() von invoke later setze wird ja nie was eingefügt oder?

 

[Michael...]

Wenn ichs in das run() von invoke later setze wird ja nie was eingefügt oder?

Warum? Die Textarea wird ja anschließend per for Schleife befüllt.

 

[MrZylinder]

Ja es wird doch dann immer eingefügt und direkt wieder gelöscht...oder nicht?

 

[Michael...]

Ja es wird doch dann immer eingefügt und direkt wieder gelöscht...oder nicht?

Ich versteh das Problem nicht?

SwingUtilities.invokeLater(new Runnable(){
    public void run() {
        ta.setText("");
        for(int i=0;i<list1.size();i++) {
            ta.append(list1.get(i));
        }
    }
});

 

[MrZylinder]

genau das funktioniert net -.-'' verstehe net warum

 

[Michael...]

Dann wäre eine KSKB hilfreich, an dem wir nachvollziehen können warum etwas nicht funktioniert.