Paylaşım Bariyeri D

Question

'deki iletiler arasında paylaşın D düzgün bir şekilde çalışmak için D engel engelini almaya çalışırken bir zaman geçiriyorum. Şu anda herhangi bir derleyici hatası almıyorum, ancak engele her ulaştığında bölümleme hatası alıyorum. Ben ana işlevi tamamen bariyer tanımlayan denedim

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

ama dmd yakınır:: İşte ne temelde

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

Ben de paylaşılan değişken ve I olarak geçen denedim bu olsun: Eğer ana iş parçacığı barrier set, sadece ana iş parçacığı bunu ayarlandığında

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

Answer 1

Küresel değişkenler D'de varsayılan olarak parçacığı yerel; Diğer iş parçacıkları için, barrier, null olacaktır.

__gshared Barrier barrier; 

iplik spawn işlevi yalnızca, shared olarak işaretlenmiş veri geçirmediğinizi

keşfettim verir gibidir: Bir kesmek biraz olsa

Sen, bu iplik-küresel hale getirmek için __gshared olarak barrier işaretleyebilirsiniz. Ancak, Barrier.wait işlevi shared olarak işaretlenmediğinden, onu çoğunlukla yararsız yapan bir shared(Barrier) nesnesiyle çağıramazsınız. Başka hack olarak, wait çağırmadan önce paylaşılmamış ilk yayınlayabilmek için:

(cast()barrier).wait();