[JAVA] Synchronized LinkedList & Server Multithread

[Xfree]

Per esercitarmi in vista di un prossimo esame ho provato a fare questo semplice esercizio. Ho un server multithread che risponde alle richieste dei client inviando la data e l'ora corrente, esso memorizza in una lista l'elenco degli accessi ed attraverso una Gui (che parolona, ha solo un bottone :asd:) permette di salvare la lista su file.

Poiché alla lista possono accedervi diversi thread in maniera concorrente, spulciando la documentazione di java ho trovato che devo dichiarare la lista attraverso la classe Wrapper Collections in questo modo

List<String> list = Collections.synchronizedList(new LinkedList<String>());

Di funzionare funziona ma ho i seguenti dubbi sulla correttezza di quanto fatto:
1)Il modo che utilizzo per accedere alla lista da classi diverse dalla quale l'ho dichiarata è corretto?
La lista l'ho dichiarata nella classe MultiServer e per accedervi dalle classi MultiServerThread e Gui utilizzo il riferimento Multiserver.list.
2)La sincronizzazione della lista nella Gui è corretta?

Se notate errori, oltre ai dubbi da me espressi, ditemeli pure! ;)
Grazie anticipatamente! :)

MultiServer

import java.net.*;
import java.io.*;
import java.util.*;
import javax.swing.*;

public class MultiServer {
public static List<String> list = Collections.synchronizedList(new LinkedList<String>());
public static void main(String []args) throws IOException {
ServerSocket serverSocket = null;
boolean listening = true;
final int SERVER_PORT = 9999;

//Provo ad aprire la connessione sulla porta 9999
try {
serverSocket = new ServerSocket(SERVER_PORT);
} catch (IOException exc) {
System.out.println("Impossibile avviare il server sulla porta "+SERVER_PORT);
}

SwingUtilities.invokeLater(new Runnable() {
public void run() {
new Gui().setVisible(true);
}
});

System.out.println("Server in ascolto sulla porta "+SERVER_PORT);
while(listening)
new MultiServerThread(serverSocket.accept()).start();


serverSocket.close();

}

}

MultiServerThread

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

public class MultiServerThread extends Thread {
private Socket socket = null;

public MultiServerThread(Socket socket) {
this.socket = socket;
}

public void run() {
BufferedReader in = null;
PrintStream out = null;
DateUtils dataCorrente = new DateUtils();
SocketAddress hostRemoto = socket.getRemoteSocketAddress();
Thread currentThread = Thread.currentThread();
String threadName = currentThread.getName();
System.out.println("*==============================*");
System.out.println("Connessione da "+hostRemoto+" servita da "+threadName);
String entry = hostRemoto+"|"+threadName;
MultiServer.list.add(entry);
try {
in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
out = new PrintStream(socket.getOutputStream());
out.println(dataCorrente.now());
} catch (UnknownHostException exc) {
System.err.println("HOST SCONOSCIUTO");
} catch (SocketException exc) {
System.err.println("CONNESSIONE PERDUTA");
} catch (IOException exc) {}
}
}

Gui

import java.awt.*;
import javax.swing.*;
import java.awt.event.*;
import java.util.*;
import java.io.*;

public class Gui extends JFrame implements ActionListener {
private Toolkit toolkit;
JButton salvaLista = new JButton("Salva lista");
JPanel panel = new JPanel();
Container c;

public Gui() {

//Centra la gui
toolkit = getToolkit();
Dimension size = toolkit.getScreenSize();
setTitle("SERVER");
setSize(500,400);
setDefaultCloseOperation(DO_NOTHING_ON_CLOSE);
setLocation(size.width/2-getWidth()/2,size.height/2-getHeight()/2);

panel.add(salvaLista);
salvaLista.addActionListener(this);
c = getContentPane();
c.add(panel);
setResizable(false);

}

public void actionPerformed(ActionEvent e) {
Object o = e.getSource();
if (o == salvaLista) {

String nomeFile = "out.txt";
if(MultiServer.list.isEmpty()) {
JOptionPane.showMessageDialog(null, "Lista Vuota");
} else {
synchronized(MultiServer.list){
Iterator it = MultiServer.list.iterator();
PrintWriter out = null;
String daScrivere = null;
try {
out = new PrintWriter(new BufferedWriter(new FileWriter(nomeFile)));
} catch (IOException exc) {}

while(it.hasNext()) {
daScrivere = (String)it.next();
out.println(daScrivere);
}
out.close();
JOptionPane.showMessageDialog(null, "Lista Salvata su "+nomeFile);
}
}
}
}
}

[PGI-Bis]

E' ok.

Il memory model garantisce che i Thread vedano il campo "list" pienamente inizializzato. Il package collections richiede la sincronizzazione su list per l'iterazione.

La lista restituita da Collections.synchronizedList è sincronizzata "su sè stessa" quindi quel synchronized(list) esclude che possano esserci mutazioni concorrenti da parte del server (che produrrebbero un'eccezione in esecuzione).

Se non sbaglio c'è un leak (non è garantita la chiusura dei socket in caso di eccezione) e il booleano listening causa uno spin-loop ma non sono problemi di concorrenza.

[Xfree]

Perfetto grazie! :)
Per prima cosa mi interessava che non ci fossero problemi di concorrenza, menomale! :p

serverSocket.close() dovrei racchiuderlo in blocco try/catch, giusto?
Per spinloop cosa si intende? :fagiano: Ciclo indefinito?