Aliase zu änderbaren Thread-lokalen Daten nicht erlaubt

Question

Ich bin neu in D und ich schreibe einen einfachen Multithread-Server für die Praxis. Ein gängiges Paradigma zum Starten von Client-Handler-Threads in C besteht darin, den Dateideskriptor des neu akzeptierten() ed-Sockets an pthread_create() zu übergeben, aber Ds std.concurrency.spawn() erlaubt es mir nicht, den Socket zu übergeben, weil er veränderbar ist und zugänglich durch zwei Fäden.

Natürlich möchte ich eigentlich keinen unveränderlichen Socket (weshalb ich es nicht wirklich in den Hauptthread werfen möchte, wenn ich nicht muss) - Ich möchte einen veränderlichen einreichen und es haben gehe im Hauptthread aus dem Bereich raus. Wie würde ich darüber gehen? Sollte (/ kann) ich tid.send(s) verwenden, damit der Thread den Socket benutzt? Aus irgendeinem Grund scheint das sehr klobig zu sein.

Mein Code jetzt:

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

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

void clientHandler(Socket s) { 
    ... 
} 

Welche erzeugt: Fehler: statische assert "Aliases zu wandelbar lokalen Thread-Daten erlaubt es nicht." ... instanziiert von hier: spawn! (Socket)

Answer 1

müssen Sie die Buchse geteilt und wieder zurück in die Clienthandler

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

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

der Grund dafür werfen ist, dass alle lokalen Variablen implizit lokalen Thread werden, es sei denn shared angegeben, und nur Verweise auf gemeinsam genutzten oder unveränderlich Dose als Argument an spawn (oder send) weitergegeben werden, während Zeug nach Wert (Structs ohne Referenzen und Primitiven) übergeben wird

auch sollten Sie den close int den Handler wie bei Ihrer aktuellen Implementierung der Sockel wird wahrscheinlich geschlossen werden, bevor die neul y launched thread hat eine Chance zu laufen

Answer 2

Das Problem hier ist nicht der Socket, der eine lokale Variable ist. Es ist der clientHandler, dessen Deklaration du nicht gezeigt hast, aber klar ist es thread-lokal wie es in der Fehlermeldung heißt, wenn es pro akzeptiertem Socket einen neuen geben sollte. Der Hinweis ist das Wort "Alias", das sich auf den Operator & bezieht.