Torna indietro   Hardware Upgrade Forum > Software > Programmazione

Ecovacs Goat O1200 LiDAR Pro: la prova del robot tagliaerba con tagliabordi integrato
Ecovacs Goat O1200 LiDAR Pro: la prova del robot tagliaerba con tagliabordi integrato
Nuova frontiera per i robot tagliaerba, con Ecovacs GOAT O1200 LiDAR Pro che riconosce l'ambiente in maniera perfetta, grazie a due sensori LiDAR, e dopo la falciatura può anche rifinire il bordo con il tagliabordi a filo integrato
Recensione Samsung Galaxy S26+: sfida l'Ultra, ma ha senso di esistere?
Recensione Samsung Galaxy S26+: sfida l'Ultra, ma ha senso di esistere?
Equilibrio e potenza definiscono il Samsung Galaxy S26+, un flagship che sfida la variante Ultra e la fascia alta del mercato con il primo processore mobile a 2nm. Pur mantenendo l'hardware fotografico precedente, lo smartphone brilla per un display QHD+ da 6,7 pollici d'eccellenza, privo però del trattamento antiriflesso dell'Ultra, e per prestazioni molto elevate. Completano il quadro la ricarica wireless a 20W e, soprattutto, un supporto software settennale
Zeekr X e 7X provate: prezzi, autonomia fino a 615 km e ricarica in 13 minuti
Zeekr X e 7X provate: prezzi, autonomia fino a 615 km e ricarica in 13 minuti
Zeekr sbarca ufficialmente in Italia con tre modelli elettrici premium, X, 7X e 001, distribuiti da Jameel Motors su una rete di 52 punti vendita già attivi. La Zeekr X parte da 39.900 euro, la 7X da 54.100: piattaforma a 800V, chip Snapdragon di ultima generazione, ricarica ultraveloce e un'autonomia dichiarata fino a 615 km WLTP. Le prime consegne sono previste a metà aprile
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


Ecovacs Goat O1200 LiDAR Pro: la prova del robot tagliaerba con tagliabordi integrato Ecovacs Goat O1200 LiDAR Pro: la prova del robot...
Recensione Samsung Galaxy S26+: sfida l'Ultra, ma ha senso di esistere? Recensione Samsung Galaxy S26+: sfida l'Ultra, m...
Zeekr X e 7X provate: prezzi, autonomia fino a 615 km e ricarica in 13 minuti Zeekr X e 7X provate: prezzi, autonomia fino a 6...
Marathon: arriva il Fortnite hardcore Marathon: arriva il Fortnite hardcore
HP Imagine 2026: abbiamo visto HP IQ all’opera, ecco cosa può (e non può) fare HP Imagine 2026: abbiamo visto HP IQ all’opera, ...
Star Wars Eclipse in difficoltà: ...
Gestione del team e romance organiche: l...
Intel lancia Core Ultra X9 378H: hardwar...
Tomodachi Life non supporterà Handheld M...
Identificati i boss di REvil e GandCrab:...
Google Chrome 148 introduce il caricamen...
Tomb Raider: Legacy of Atlantis, l'uscit...
Casa Bianca: proposto un budget ridotto ...
Telecamere Arlo in offerta su Amazon: Es...
Maine primo stato USA a vietare i data c...
DDL PMI, stop alle false recensioni: le ...
Classifiche JustWatch marzo: Una battagl...
iPhone Fold a rischio ritardo: problemi ...
Artemis II: raggiunto il punto più...
LG OLED e Hisense QLED da 85'' e 98'': s...
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: 13:48.


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