Threads & Pipes --> Ist eine Übergabe von Objekten mö

[Willi2501]

Hallo!

Ich möchte 2 Threads via Pipe verbinden und ganze Objekte die in einem Vektor gespeichert sind vom 1. zum 2. übergeben.
Weiß jemand wie das funktioniert bzw funktioniert das überhaupt?!

Danke!

 

[Wildcard]

Welche Rolle soll die Pipe dabei spielen? Warum greift der andere Thread nicht direkt auf die Objekte zu?

 

[Willi2501]

Es geht um ein Projekt im Studium.

Sieht bisher so aus.
Es werden über die Konsole Adressinformationen von Personen eingegeben. Diese werden als Personenobjekte in einem Vector gespeichert und schlussendlich in einer Datei abgelegt.
Funktionalität des Programms sieht momentan so aus.
Alles per Konsole:
Personen mit Adressinformationen anlegen
Daten aus Datei laden
Daten anzeigen
Daten in Datei speichern
Datei löschen

Im Zuge des Projektes sollen jetzt die Datei I/O Operationen und die Consolenoperationen in Threads aufgesplittet werden. Im nächsten Projekt soll es dann zu einer Client/Server Anwendung kommen. Und deshalb sollen laut Prof die Threads über Pipes kommunizieren.
Also User macht ne Eingabe, Personenobjekt(e) wird erstellt (1.Thread) und will dieses zum Schluss in Datei abspeichern (2.Thread).

Wie bekomme ich diese Kommunikation/Datenaustausch über Pipes hin?!

 

[Wildcard]

ObjectOutputStream und PipedOutputStream wären in diesem Fall deine Stichworte.

 

[Willi2501]

ObjectOutputStream und PipedOutputStream wären in diesem Fall deine Stichworte.

habe ich mir auch schon gedacht, komme nur nicht drauf, die ich die auf den Vector anwenden kann.

könntest du mal code zeigen wie das gehen könnte?!

Momentan sieht die Speicherung wie folgt aus(momentan noch Objektzerlegung in Strings zum Speichern):


public void daten_speichern()
{


File file1 = new File("adreli_con.txt");
file1.delete();

try
{

RandomAccessFile file2 = new RandomAccessFile("adreli_con.txt", "rw");

Iterator<Person> it = vec.iterator();

while (it.hasNext())
{
Person pers = (Person)it.next();

// Datensatz wird in der Form formatieren_speichern
// in der Datei gespeichert (momentan noch als String)
file2.writeBytes((pers.formatieren_speichern()));
}

// Die Verbindung zum File wird geschlossen
file2.close();


System.out.println("\n\n*******Die Datensaetze wurden"+
" erfolgreich gespeichert...*******\n\n");
}


catch (Exception e)
{
System.out.println("Daten konnten nicht gespeichert werden!");
System.out.println("Fehler: " + e);
}

} // Ende void daten_speichern

 

[DocRandom]

Moin Willi!

Ich kann Dir zumindest mal demonstrieren wie die Pipe funktionieren kann:

package willi2501;

import java.io.BufferedWriter;
import java.io.IOException;
import java.io.PipedWriter;

public class ThreadProduzent extends Thread{
	
	private PipedWriter pipeOut = null;
	private BufferedWriter bw = null;
	
	public ThreadProduzent(PipedWriter pipeOut) {
		this.pipeOut = pipeOut;
		bw = new BufferedWriter(pipeOut);
	}
	
	public void run() {
		try {
			bw.write("Halli, Hallo\n");
			bw.flush();
			bw.write("Quit\n");
			bw.flush();
		} catch (IOException ioe) {
			//
		}
	}
}

package willi2501;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.PipedReader;

public class ThreadKonsument extends Thread{
	
	private PipedReader pipeIn = null;
	private BufferedReader br = null;
	
	public ThreadKonsument(PipedReader pipeIn) {
		this.pipeIn = pipeIn;
		br = new BufferedReader(pipeIn);
	}
	
	public void run() {
		
		String zeile = "";
		while(!zeile.equalsIgnoreCase("QUIT")) {
			try {
				zeile = br.readLine();
				System.out.println(zeile);
			} catch (IOException ioe) {
				//
			}
		}
	}
}

package willi2501;

import java.io.IOException;
import java.io.PipedReader;
import java.io.PipedWriter;

public class ThreadKommunikation {

	public ThreadKommunikation() {
		PipedReader pipeIn = new PipedReader();
		PipedWriter pipeOut = null;
		try {
			pipeOut = new PipedWriter(pipeIn);
		} catch (IOException ioe) {
			//
		}
		ThreadProduzent tp = new ThreadProduzent(pipeOut);
		ThreadKonsument tk = new ThreadKonsument(pipeIn);
		tp.start();
		tk.start();
	}
}

package willi2501;

public class Main {

	public static void main(String[] args) {
		ThreadKommunikation tk = new ThreadKommunikation();

	}

}

Ich hoffe das bringt Dich etwas weiter

lg
DocRandom

 

[Willi2501]

ja danke hat geholfen.
jetzt habe ich nur nen anderes problem.

und zwar:

nach aufrufen der threads und objektübermittlung kommt es jetzt zu seltsamen phänomenen. es werden methoden aufgerufen bzw es kommen in der konsole methodenfragmente zum vorschein, die ich überhaupt nicht ausführen wollte oder ausgeführt habe. und das mit keiner regelmäßigkeit.
also mdie ethoden existieren klar, werden aber nicht von mir über die konsole aufgerufen!

Weiß jemand was das ein könnte?

 

[DocRandom]

Moin Willi!

Ohne Deinen Code zu kennen, wird man Dir ned weiterhelfen können!

lg
DocRandom