|
|||||||
|
|
|
![]() |
|
|
Strumenti |
|
|
#1 |
|
Senior Member
Iscritto dal: Aug 2001
Messaggi: 9538
|
[JAVA] Synchronized LinkedList & Server Multithread
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
) 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 Codice:
List<String> list = Collections.synchronizedList(new LinkedList<String>()); 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 Codice:
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();
}
}
Codice:
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) {}
}
}
Codice:
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);
}
}
}
}
}
|
|
|
|
|
|
#2 |
|
Senior Member
Iscritto dal: Nov 2004
Città: Tra Verona e Mantova
Messaggi: 4553
|
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.
__________________
Uilliam Scecspir ti fa un baffo? Gioffri Cioser era uno straccione? E allora blogga anche tu, in inglese come me! |
|
|
|
|
|
#3 |
|
Senior Member
Iscritto dal: Aug 2001
Messaggi: 9538
|
Perfetto grazie!
Per prima cosa mi interessava che non ci fossero problemi di concorrenza, menomale! serverSocket.close() dovrei racchiuderlo in blocco try/catch, giusto? Per spinloop cosa si intende? Ciclo indefinito?
|
|
|
|
|
| Strumenti | |
|
|
Tutti gli orari sono GMT +1. Ora sono le: 11:15.










) permette di salvare la lista su file.
Ciclo indefinito?








