Hello,
Im starting one process in the main thread who in turn is going
to kick off another process but has no way of passing along
main's Tid, hence the shared(Tid) nonsense.
* This works in serial (i.e. change workUnitSize > x.length in
mains foreach loop).
* It also works when passing the tid directly into f.run(mainTid)
with workUnitSize == 1
But I get a crash when attempting to run in parallel with a
"shared" tid (see below).
Any ideas how to make this work?
Thanks,
Josh
// garbage: newb playing with threads
module test;
import core.thread;
import std.concurrency, std.parallelism, std.stdio;
shared(Tid) mainTid;
struct Foo {
void run() {
Thread.sleep(dur!"seconds"(1));
writeln(cast(Tid)mainTid);
send(cast(Tid)mainTid, true);
}
}
void someAction(Tid tid) {
mainTid = cast(shared(Tid))tid;
}
void main() {
Foo[] x = [Foo(), Foo(), Foo()];
spawn( &someAction, thisTid );
foreach(f; taskPool.parallel(x, 1)) {
f.run();
receiveTimeout(dur!"seconds"(3),
(bool x) { writeln("received"); }
);
}
}
// exception output:
core.exception.AssertError@/usr/share/dmd/src/phobos/std/concurrency.d(1007):
null this
----------------
5 test 0x000000010604a4ad
_d_assert_msg + 69
6 test 0x0000000106032523 bool
std.concurrency.MessageBox.get!(core.time.Duration, void
function(bool)*).get(scope core.time.Duration, scope void
function(bool)*) + 83
7 test 0x00000001060324bb bool
std.concurrency.receiveTimeout!(void
function(bool)*).receiveTimeout(core.time.Duration, void
function(bool)*) + 59
8 test 0x000000010602c5c7 void
test.main().int __foreachbody1416(ref test.Foo) + 71
9 test 0x00000001060320f0 int
std.parallelism.ParallelForeach!(test.Foo[]).ParallelForeach.opApply(scope
int delegate(ref test.Foo)).void doIt() + 256
10 test 0x00000001060583f4 void
std.parallelism.run!(void delegate()).run(void delegate()) + 20
11 test 0x000000010605800c void
std.parallelism.__T4TaskS213std11parallelism3runTDFZvZ.Task.impl(void*)
+ 24
12 test 0x0000000106056da3 void
std.parallelism.AbstractTask.job() + 15
13 test 0x0000000106056df9 void
std.parallelism.TaskPool.doJob(std.parallelism.AbstractTask*) + 33
14 test 0x0000000106056f20 void
std.parallelism.TaskPool.workLoop() + 132
15 test 0x000000010603f915 void
core.thread.Thread.run() + 49
16 test 0x000000010603ec5a
thread_entryPoint + 334
17 libsystem_c.dylib 0x00007fff9681f742
_pthread_start + 327
18 libsystem_c.dylib 0x00007fff9680c181
thread_start + 13
19 ??? 0x0000000000000000 0x0 + 0
----------------
