[JAVA] Lavorare sullo stesso oggetto in thread diversi

[vi1985]

Salve a tutti ed auguri posticipati di Natale.
Come da titolo avrei un problema che mi attanaglia: come faccio a lavorare sullo stesso oggetto in thread diversi (sincronizzati) dello stesso package?
Avendo una coda dovrei da una parte accodare, dall'altra implementare un'attesa e deaccodare.
Ringrazio chiunque, di buon cuore, risponda.

[andbin]

Originariamente inviato da vi1985
Avendo una coda dovrei da una parte accodare, dall'altra implementare un'attesa e deaccodare.

Se ti va bene una coda con un limite massimo nella lunghezza (bounded), allora usa la classe java.util.concurrent.ArrayBlockingQueue.

[vi1985]

Come struttura di dati ho usato una LinkedList.
Ho passato questa coda nel costruttore del Thread, fatto in questo modo:

public class MioThread implements Runnable{
	
	private ElencoPersone coda;

	public SportelloThread(coda){
	this.coda = coda;
}

	public void run(){	
	while(coda.getStato()){
	try{
        coda.wait();
}catch(InterruptExcpetion e){
	// deaccoda
}
}
}

dove ElencoPersone è:

public class ElencoPersone {
	

	
	public ElencoPersone(boolean stato){
		this.stato = stato;
	}
	
	private LinkedList<Persona> coda;
	private boolean stato;
	
	public void aggiungi(Persona p){
		if(stato == true)
			coda.add(cliente);
	}
	
	public synchronized Cliente rimuovi() throws Exc{
		if(coda.isEmpty())
			throw new Exc;
		return coda.remove();
	}
	
	public void setStato(boolean stato){
		this.stato = stato;
	}
	
	public boolean getStato(){
		return stato;
	}
}

Ora il problema è un altro.
Non avendo mai avuto modo di affrontare questo tipo di problema, la condizione da verificare nel run del thread da cosa deve dipendere?

[andbin]

Ciò che hai scritto non mi sembra né valido né thread-safe. Io ti ho suggerito ArrayBlockingQueue perché è fatta apposta per queste cose: è una coda, è thread-safe e alcuni suoi metodi sono "bloccanti".
Se vuoi fare una cosa del genere solamente con LinkedList è fattibile ma il tutto va gestito con criterio e in modo opportuno.

[vi1985]

Il problema che mi preme è un altro.
Anche usando la ArrayBlockingQueue (che sto vedendo dalla documentazione) come faccio a lavorare con essa su thread separati?
Devo comunque andare a creare una nuova classe di Thread nel quale effettuare le operazioni che desidero, anche perché è essenziale la gestire la sincronizzazione.

[andbin]

Originariamente inviato da vi1985
Anche usando la ArrayBlockingQueue (che sto vedendo dalla documentazione) come faccio a lavorare con essa su thread separati?

I thread devi crearli e gestirli tu!
L'unica cosa certa è che ArrayBlockingQueue è thread-safe, cioè vuol dire che è utilizzabile in modo "sicuro" da più thread. Tutto qua.

Una cosa è la gestione dei thread, un'altra è la implementazione di una classe che sia thread-safe, requisito fondamentale affinché uno stesso oggetto di questa classe possa essere usato in modo sicuro da più thread.

Volendo farlo con LinkedList, ecco:

class ElencoPersone
{
    private LinkedList<Persona> coda;

    public ElencoPersone ()
    {
        coda = new LinkedList<Persona> ();
    }
    
    public synchronized void inserisci (Persona p)
    {
        coda.add (p);
        notifyAll ();
    }

    public synchronized Persona estrai ()
        throws InterruptedException
    {
        while (coda.isEmpty ())
            wait ();

        return coda.remove ();
    }
}

Nota come entrambi i metodi siano synchronized e nota come in estrai() ci sia la "logica" di blocking (se si vuol farlo blocking ovviamente .... non è obbligatorio, si potrebbe anche lanciare una eccezione).

[rosario.russo71]

Scusa il main dov'è ??? Per poter provare questa coda bloccante ...

[andbin]

Originariamente inviato da rosario.russo71
Scusa il main dov'è ???

La classe ElencoPersone che avevo postato rappresentava solo una lista di oggetti Persona ... basta ... tutto qui.
Non c'è un main() in quella classe ... perché è solo una "collezione".
Vuoi provarla? Definisci un'altra classe che ha il main, istanzia un ElencoPersone, ecc....

[rosario.russo71]

ok, fatto grazie...