Torna indietro   Hardware Upgrade Forum > Software > Programmazione

Plaud NotePin S, il registratore IA si fa indossabile (ma è facile da perdere)
Plaud NotePin S, il registratore IA si fa indossabile (ma è facile da perdere)
Quattro modi di indossarlo, stessa app del Plaud Note Pro e integrazione con il desktop. Il registratore IA da indossare di Plaud eccelle in mobilità, ma resta vincolato all'abbonamento ed è facile da perdere
Redmi Watch 6 in prova: lo smartwatch con ampio display da 2000 nit a meno di 100 euro
Redmi Watch 6 in prova: lo smartwatch con ampio display da 2000 nit a meno di 100 euro
Xiaomi ha portato Redmi Watch 6 anche sul mercato italiano, puntando su un display AMOLED da 2,07 pollici con picco di luminosità a 2000 nit, frame in alluminio da 9,9mm e un'autonomia dichiarata di 12 giorni. Lo smartwatch gira su HyperOS 3 e integra GPS, Bluetooth 5.4 e oltre 150 sport mode. Il tutto a meno di 100 euro
Mad Catz M.M.O. 7+: lo stesso DNA del R.A.T. 8+ ADV, ma con molti più pulsanti
Mad Catz M.M.O. 7+: lo stesso DNA del R.A.T. 8+ ADV, ma con molti più pulsanti
Con 22 tasti, il pulsante 5D, lo Shift Mode e il sensore PixArt 3395 da 26.000 DPI, il nuovo mouse wireless di Mad Catz si rivolge in modo preciso ai giocatori di MMO e RPG. Ma chi conosce già il R.A.T. 8+ ADV si accorgerà subito di quanto i due prodotti condividano, e di dove invece divergono
Tutti gli articoli Tutte le news

Vai al Forum
Rispondi
 
Strumenti
Old 04-06-2009, 14:50   #1
Xfree
Senior Member
 
L'Avatar di Xfree
 
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>());
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
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();
    
  }
  
}
MultiServerThread
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) {}
  }
}
Gui
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);
          }
        }
    }
  }
}
Xfree è offline   Rispondi citando il messaggio o parte di esso
Old 04-06-2009, 15:42   #2
PGI-Bis
Senior Member
 
L'Avatar di PGI-Bis
 
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!
PGI-Bis è offline   Rispondi citando il messaggio o parte di esso
Old 04-06-2009, 16:04   #3
Xfree
Senior Member
 
L'Avatar di Xfree
 
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?
Xfree è offline   Rispondi citando il messaggio o parte di esso
 Rispondi


Plaud NotePin S, il registratore IA si fa indossabile (ma è facile da perdere) Plaud NotePin S, il registratore IA si fa indoss...
Redmi Watch 6 in prova: lo smartwatch con ampio display da 2000 nit a meno di 100 euro Redmi Watch 6 in prova: lo smartwatch con ampio ...
Mad Catz M.M.O. 7+: lo stesso DNA del R.A.T. 8+ ADV, ma con molti più pulsanti Mad Catz M.M.O. 7+: lo stesso DNA del R.A.T. 8+ ...
Radeon RX 9070 GRE, AMD la porta in tutto il mondo | Recensione Gigabyte Gaming OC Radeon RX 9070 GRE, AMD la porta in tutto il mon...
Reolink OMVI 3i WiFi: videosorveglianza più intelligente e facile da usare Reolink OMVI 3i WiFi: videosorveglianza pi&ugrav...
LG presenta in Italia le gamme TV Micro ...
Sette anni dopo l'annuncio, The Wolf Amo...
'Non avrete aumenti': la decisione shock...
TIM lancia il Pass Mondiali DAZN: 104 pa...
Tesla Roadster, promessa o miraggio? La ...
Mark Hamilton, la tavola periodica del m...
Hanger 13 annuncia Uomo d'Onore: espansi...
La battaglia delle HBM4 entra nel vivo: ...
Dopo 12 anni torna Alien: Isolation. Ecc...
ADATA Trusta ridurrà i costi di i...
SpaceX fornirà 110.000 GPU NVIDIA...
Hyundai IONIQ 6 N-Line, prova in antepri...
Sospesi i lavori di riparazione delle pe...
Formula V vi farà cambiare l'airf...
Netflix usa l'IA generativa per battere ...
Chromium
GPU-Z
OCCT
LibreOffice Portable
Opera One Portable
Opera One 106
CCleaner Portable
CCleaner Standard
Cpu-Z
Driver NVIDIA GeForce 546.65 WHQL
SmartFTP
Trillian
Google Chrome Portable
Google Chrome 120
VirtualBox
Tutti gli articoli Tutte le news Tutti i download

Strumenti

Regole
Non Puoi aprire nuove discussioni
Non Puoi rispondere ai messaggi
Non Puoi allegare file
Non Puoi modificare i tuoi messaggi

Il codice vB è On
Le Faccine sono On
Il codice [IMG] è On
Il codice HTML è Off
Vai al Forum


Tutti gli orari sono GMT +1. Ora sono le: 11:53.


Powered by vBulletin® Version 3.6.4
Copyright ©2000 - 2026, Jelsoft Enterprises Ltd.
Served by www3v