[Java] Stream e Thread

[Xanakro]

Salve a tutti! E' il mio primo post, per cui mi presento. Mi chiamo Adriano e studio ingegneria informatica. Posto il codice per chiarezza, lo commenterò alla fine.

import java.io.*;
import java.lang.*;
import java.util.*;
import java.net.*;

//Devo fare in modo che partano due thread, uno per il cliente e uno per il taxi

public class Gestore implements Runnable{
	private LinkedList <Taxi> taxilist = new LinkedList <Taxi> ();
	private ServerSocket ss;
	private DataInputStream is;
	private DataOutputStream os;
	private ObjectInputStream ois;
	private BufferedReader br;
	private Gestore gest;
	private Socket cs;
	
	public static void main(String args[]) throws IOException{
		System.out.println("Sono il Server Gestore");
		Gestore g = new Gestore();
		g.init();
	}
	
	public void init(){
		try{
			ss = new ServerSocket(50000);
			while(true){
				cs = ss.accept();
				os = new DataOutputStream(cs.getOutputStream());
				is = new DataInputStream(cs.getInputStream());
				br = new BufferedReader(new InputStreamReader(cs.getInputStream()));
				System.out.println("Identificazione In corso");
				boolean id;
				id = is.readBoolean();//se leggo true è un taxi, se leggo false è un cliente
				Thread.sleep(5000);
				if(id == true){
					gest = new Gestore();
					Thread tg = new Thread(gest);
					tg.start();
				}
			}
		}
		catch(IOException e) {System.out.println("Error "+e);}
		catch(InterruptedException e) {System.out.println("Error "+e);}
	}
	
	public void run(){
		//thread taxi
		try{
			System.out.println("Benvenuto Taxi");
			//Qui si blocca, dice che lo stream is è null
			//se copio il codice dentro l'if invece che far partire il thread funziona.
			int x = is.readInt();
			int y = is.readInt();
			boolean libero = is.readBoolean();
			int tid = taxilist.size()+1;
			os.writeInt(tid);
			Posizione pos = new Posizione(x,y);
			Taxi taxiapp = new Taxi(pos,libero,tid);
			taxilist.add(taxiapp);
			os.writeBoolean(true);
		}
		catch(IOException e){System.out.println("Errorrrrrrrr");}
	}
}

Dunque questo server deve gestire le richieste di due client: taxi e cliente. Per ora ho implementato solo la parte relativa al taxi. L'errore è alla riga 53 ovvero

int x = is.readInt();

A runtime ricevo una eccezzione di tipo NullPointerException quindi è come se lo stream is sia null. Dentro il metodo init() gli stream funzionano perfettamente, quindi il problema è evidentemente del run(). Spero di essere stato chiaro e vi ringrazio per l'attenzione

[serioja90]

Ciao, il problema potrebbe essere legato al fatto che nel if crei un nuovo Gestore, che però non viene inizializzato con la funzione init(), per cui è probabile che lo stream non sia inizializzato per quel gestore.
Spero di essermi spiegato.

[andbin]

Originariamente inviato da Xanakro
A runtime ricevo una eccezzione di tipo NullPointerException quindi è come se lo stream is sia null. Dentro il metodo init() gli stream funzionano perfettamente, quindi il problema è evidentemente del run().

Nel main() fai:

Gestore g = new Gestore();

E questo è ok per avere la istanza su cui invocare init(). Ma nel init() ad un certo punto per creare il thread fai:

gest = new Gestore();
Thread tg = new Thread(gest);

Hai istanziato un nuovo oggetto Gestore e in questo non vengono inizializzati i vari stream.

Il mio consiglio è quello di separare meglio le cose: cioè la parte main+init dalla parte che definisce il "lavoro" del thread.

[serioja90]

Si, però creando un nuovo gestore, viene creato un nuovo oggetto, per cui chiamando il metodo run() verrà utilizzato l'is di quel oggetto.
In pratica non viene utilizzato l'InputStream inizializzato nel metodo init().

[LeleFT]

Originariamente inviato da serioja90
[...]per cui chiamando il metodo run() [...]

Il metodo run() non deve MAI essere chiamato direttamente dal programmatore.
Il programmatore deve limitarsi a chiamare il metodo start(). Sarà la JVM ad invocare il metodo run().


Ciao.

[serioja90]

Potresti risolvere il problema passando al nuovo Gestore gli stream inizializzati.

[Xanakro]

Grazie per le risposte!
Quindi se ho ben capito secondo voi conviene creare una nuova classe con solo il metodo run()?
Mi sorge un dubbio. Dato che in init() ho

cs = ss.accept();

come faccio a prendere la socket nel run della nuova classe?

@leleft: sisi chiamo il metodo start() ho scritto male chiedo venia

[LeleFT]

Originariamente inviato da Xanakro
Grazie per le risposte!
Quindi se ho ben capito secondo voi conviene creare una nuova classe con solo il metodo run()?
Mi sorge un dubbio. Dato che in init() ho

cs = ss.accept();

come faccio a prendere la socket nel run della nuova classe?

Gliela passi come parametro al costruttore, ad esempio...

@leleft: sisi chiamo il metodo start() ho scritto male chiedo venia

Sì, il mio intervento era in risposta a serioja90

Ciao.

[Xanakro]

Perfetto! Grazie mille a tutti per l'aiuto

[andbin]

Originariamente inviato da Xanakro
Quindi se ho ben capito secondo voi conviene creare una nuova classe con solo il metodo run()?
Mi sorge un dubbio. Dato che in init() ho

cs = ss.accept();

come faccio a prendere la socket nel run della nuova classe?

Da quanto ho capito hai questo "server" che deve gestire 2 tipi di "client": un "taxi" o un "cliente".

Bene potresti avere un tuo GestoreRunnable che nel run() si "smazza" la cosa andando a vedere quel boolean e facendo cose diverse a seconda del valore.
Oppure avere 2 runnable: GestoreRunnableTaxi e GestoreRunnableCliente. Chiaramente la logica di riconoscimento la fai "a monte" (concettualmente come hai già fatto).
Scegli tu.