Share Barrier через потоки в D

Question

У меня чертовски время, пытаясь заставить барьерную синхронизацию в D работать правильно. В настоящее время я не получаю ошибок компилятора, но каждый раз, когда он достигает барьера, я получаю ошибку сегментации. Вот в основном то, что у меня есть:

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(); 
} 

Я попытался полностью определяя барьер в основной функции, но МДД жалуется:

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

Я также попытался передать его в качестве общей переменной и I получить это:

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

Answer 1

Глобальные переменные являются поточно-локальная по умолчанию в D. при установке barrier в основном потоке, вы только установить его в основном потоке; для других потоков, barrier будет null.

Вы можете отметить barrier в __gshared, чтобы сделать его поточно-глобальный, хотя это немного рубить:

__gshared Barrier barrier; 

Функция порождения потока позволяет только передачу данных, помеченных как shared, как вы обнаружили. Однако, поскольку функция Barrier.wait не отмечена как shared, вы не можете назвать ее объектом shared(Barrier), что делает его в основном бесполезным. В качестве другого хака, вы можете бросить его неразделенные первый перед вызовом wait:

(cast()barrier).wait();