Corrispondenza ArrayList tra connessioni socket

Question

Ho un problema. La mia convinzione è che abbia qualcosa a che fare con la concorrenza o la sincronizzazione dei thread, anche se non riesco a capire cosa sta succedendo.

Questa è la descrizione del flusso di dati per l'oggetto FriendRequestList.

Dal lato client inviamo una richiesta di amicizia a un altro utente (lavoratore). Quindi inviamo la richiesta e aggiungiamo il nostro nome utente al loro elenco User.incFriendReq. L'istanza è un ArrayList solo per riferimento piacevole.

Così ora inviamo la richiesta al server per ricevere la nostra lista di richieste di amicizia (FriendRequestList.java).

Quindi ora il problema. Se utilizzo questo codice sotto l'utente non vedrà la richiesta di amicizia prima che termini la sua connessione (logout), che chiuderà la connessione. Quando accederà, vedrà solo la richiesta nella sua lista.

codice lato server:

... Worker.java ...

private Object getFriendRequests() { 
    User me = Data.getUser(myUserName); 
    if (me == null) { 
     return new NoSuchUserException(); // Don't worry about it ;) 
    } 

    return new FriendRequestList(me.getFriendReq()); 
} 

... User.java ...

private List<String> incFriendReq; 

public List<String> getFriendReq() { 
    return incFriendReq; 
} 

lato client

... Comunicazioni n.java ...

public FriendRequestList getRequests() { 
    sendObject(new GetRequests()); 
    return inputHandler.containsRequests(); 
} 

... MessageListener.java ...

public void run() { 
    ... 
    FriendRequestList requests = communication.getRequests(); 
    update(requestList, requests); 
    // Here we have the problem. requests.size is never different from 0 
} 

Come mai, se aggiorno Worker.java per fare questo, invece:

private Object getFriendRequests() { 
    User me = Data.getUser(myUserName); 
    if (me == null) { 
     return new NoSuchUserException(); 
    } 
    return new FriendList(me.getFriends().stream().collect(Collectors.toList())); 
} 

L'istante l'altro utente richiede la mia amicizia, vedo la richiesta sulla mia lista. Cosa dà? Mi sembra che il dato sottostante non sia aggiornato, condizioni di gara o qualcosa del genere. Ma la correzione è il modo in cui recupero i dati sul lato server, utilizzando uno stream.

Per favore qualcuno spieghi e anche come sarebbe stato fatto in Java 7 prima che i flussi risolvessero il mio, per me, un problema curioso.

Su una nota

voglio aggiungere che gli utenti sono collocati all'interno di un LinkedBlockingDeque e recuperare dall'oggetto Data, una risorsa condivisa per i lavoratori.

Answer 1

Mi sembra che restituire l'elenco incFriendReq direttamente in getFriendReq sia una delle fonti del problema. Quando si utilizza java 8 e si esegue lo streaming di un elenco in un nuovo elenco, si sta solo effettuando una copia, quindi non vi sono aggiunte utili. In questo caso, il codice sul lato server dovrebbe funzionare anche utilizzando new ArrayList<>(me.getFriends()).

Verificherei che tutti gli accessi alla lista siano sincronizzati correttamente e che tu sappia dove e quando tale lista viene modificata.