app.d 1.0 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950
  1. import std.stdio;
  2. /**/
  3. // test1
  4. //import std.parallelism : defaultPoolThreads;
  5. import std.concurrency : spawn;
  6. import core.time : Duration, dur;
  7. import core.thread : Thread;
  8. import test1 : test1_spawner;
  9. /**/
  10. /*
  11. // test2
  12. import std.concurrency : spawn;
  13. import core.time : Duration, dur;
  14. import core.thread : Thread;
  15. import test2 : test2_spawner;
  16. */
  17. /*
  18. // test3
  19. //import std.parallelism : defaultPoolThreads;
  20. import std.concurrency : spawn, send;
  21. import core.time : Duration, dur;
  22. import core.thread : Thread;
  23. import test3 : test3_spawner;
  24. */
  25. void main(){
  26. //writeln("defaultPoolThreads = ", defaultPoolThreads()); // 19
  27. //defaultPoolThreads(8); // changes nothing because all threads works on 1 CPU core, not on multicores..(
  28. //writeln("defaultPoolThreads = ", defaultPoolThreads()); // 8
  29. spawn(&test1_spawner); // test1 run
  30. //spawn(&test2_spawner); // test2 run
  31. //spawn(&test3_spawner); // test3 run
  32. //Thread.sleep(dur!"seconds"(125));
  33. Thread.sleep(dur!"seconds"(30));
  34. writeln("hello here!");
  35. }