Share Barrier über Threads in D

Question

Ich habe eine Menge Zeit mit dem Versuch, die Barrieresynchronisation in D richtig zu funktionieren. Ich erhalte derzeit keine Compilerfehler, aber jedes Mal, wenn die Barriere erreicht wird, erhalte ich einen Segmentierungsfehler. Hier ist im Grunde, was ich habe:

import std.stdio; 
import std.conv; 
import std.concurrency; 
import core.thread; 
import core.sync.barrier; 

//create barrier 
Barrier barrier; 

void the_thread() 
{ 
    barrier.wait(); //I get a segmentation fault here 
} 

void main(string[] args) 
{ 
    int threads = to!int(args[1]); //number of threads 

    //init barrier 
    barrier = new Barrier(threads); 

    //launch threads 
    foreach(i; 0 .. threads) 
    { 
     spawn(&the_thread); 
    } 
    thread_joinAll(); 
} 

Ich habe versucht, die Definition der Barriere vollständig in der Hauptfunktion, aber DMD klagt:

static assert "Aliases to mutable thread-local data not allowed." 

Ich habe auch versucht, es als eine gemeinsame Variable vorbei und ich erhalten diese:

non-shared method core.sync.barrier.Barrier.wait is not callable using a shared object 

Answer 1

globale Variablen lokalen thread~~POS=TRUNC in D. standardmäßig sind, wenn Sie barrier in Ihrem Haupt-Thread gesetzt, können Sie es nur im Hauptthread gesetzt; für die anderen Threads wird barriernull sein.

Sie können barrier als __gshared zu markieren, um es globalen Thread, obwohl es ein bisschen wie ein Hack ist:

__gshared Barrier barrier; 

Die Funktion Thread laichen erlaubt nur Daten markiert als shared vorbei, wie Sie entdeckt haben. Da die Barrier.wait-Funktion jedoch nicht als shared markiert ist, können Sie sie nicht mit einem shared(Barrier)-Objekt aufrufen, was sie größtenteils unbrauchbar macht. Als weiteres Hack, können Sie es zu unshared zuerst werfen, bevor wait Aufruf:

(cast()barrier).wait();