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!"); }