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