import std.stdio; /* // test1 //import std.parallelism : defaultPoolThreads; import std.concurrency : spawn; import core.time : Duration, dur; import core.thread : Thread; import test1 : test1_spawner; */ /* // test2 import std.concurrency : spawn; import core.time : Duration, dur; import core.thread : Thread; import test2 : test2_spawner; */ /**/ // test3 //import std.parallelism : defaultPoolThreads; import std.concurrency : spawn, send; import core.time : Duration, dur; import core.thread : Thread; import test3 : test3_spawner; /**/ void main(){ //writeln("defaultPoolThreads = ", defaultPoolThreads()); // 19 //defaultPoolThreads(8); // changes nothing because all threads works on 1 CPU core, not on multicores..( //writeln("defaultPoolThreads = ", defaultPoolThreads()); // 8 //spawn(&test1_spawner); // test1 run //spawn(&test2_spawner); // test2 run spawn(&test3_spawner); // test3 run //Thread.sleep(dur!"seconds"(125)); Thread.sleep(dur!"seconds"(30)); writeln("hello here!"); }