Alias ​​di dati locali del thread mutabili non consentiti

Question

Sono nuovo a D e sto scrivendo un semplice server multithreading per esercitarsi. Un paradigma comune per avviare i thread del gestore client in C è passare il descrittore di file del socket appena accettato() in pthread_create(), ma D's st.c.current.savewn() non mi permetterà di passare il Socket perché è mutabile e accessibile da due thread.

Ovviamente, in realtà non voglio un socket immutabile (è per questo che non voglio scriverlo nel thread principale a meno che non sia necessario) - Voglio passare uno mutabile e averlo uscire dal campo di applicazione nella discussione principale. Come andrei su questo? Dovrei (/ posso) usare tid.send(s) per permettere al thread di usare il socket? Per qualche ragione mi sembra molto schifoso.

Il mio codice ora:

void main() { 
    Socket listener = new TcpSocket; 
    ... 
    for (;;) { 
     Socket s = listener.accept(); 
     scope(exit) s.close(); 

     auto tid = spawn(&clientHandler, s); 
    } 
} 

void clientHandler(Socket s) { 
    ... 
} 

che produce: Errore: statici assert "alias ai dati thread-local mutevoli non consentita". ... istanziato da qui: spawn! (Socket)

Answer 1

è necessario lanciare la presa di comune e di nuovo nel ClientHandler

auto tid = spawn(&clientHandler, cast(shared) s); 

void clientHandler(shared Socket s) { 
    Socket sock = cast(Socket)s; 
    scope(exit)sock.close(); 
} 

la ragione di questo è che tutte le variabili locali sono implicitamente filetto locale se non specificato shared, e solo i riferimenti a Can condiviso o immutabili essere passato come argomento a spawn (o send) mentre roba passato per valore (le strutture senza riferimenti e primitivi) va bene

anche si dovrebbe mettere la stretta int il gestore come con l'implementazione corrente della presa sarà probabilmente chiuso prima della newl y thread generato ha una possibilità di eseguire

Answer 2

Il problema qui non è il socket, che è una variabile locale. È il clientHandler, la cui dichiarazione non è stata mostrata, ma chiaramente è thread-local come si dice nel messaggio di errore, quando dovrebbe essercene uno nuovo per socket accettato. Il suggerimento è la parola "alias", che si riferisce all'operatore &.