75 lines
1.3 KiB
D
75 lines
1.3 KiB
D
import std.stdio;
|
|
import core.thread;
|
|
import std.datetime;
|
|
|
|
// Yield count should be larger for a
|
|
// more accurate measurment, but this
|
|
// is just a unit tests, so don't spin
|
|
// for long
|
|
immutable uint yield_count = 1000;
|
|
immutable uint worker_count = 10;
|
|
|
|
void fiber_func()
|
|
{
|
|
uint i = yield_count;
|
|
while( --i ) Fiber.yield();
|
|
}
|
|
|
|
void thread_func()
|
|
{
|
|
uint i = yield_count;
|
|
while( --i ) Thread.yield();
|
|
}
|
|
|
|
void fiber_test()
|
|
{
|
|
Fiber[worker_count] fib_array;
|
|
|
|
foreach( ref f; fib_array )
|
|
f = new Fiber( &fiber_func );
|
|
|
|
StopWatch sw;
|
|
|
|
uint i = yield_count;
|
|
|
|
// fibers are cooperative and need a driver loop
|
|
sw.start();
|
|
bool done;
|
|
do
|
|
{
|
|
done = true;
|
|
foreach( f; fib_array )
|
|
{
|
|
f.call();
|
|
if( f.state() != f.State.TERM )
|
|
done = false;
|
|
}
|
|
} while( !done );
|
|
sw.stop();
|
|
|
|
writeln( "Elapsed time for ", worker_count, " workers times ", yield_count, " yield() calls with fibers = ",
|
|
sw.peek().msecs, "ms" );
|
|
}
|
|
|
|
void thread_test()
|
|
{
|
|
Thread[worker_count] thread_array;
|
|
|
|
foreach( ref t; thread_array )
|
|
t = new Thread( &thread_func );
|
|
|
|
StopWatch sw;
|
|
sw.start();
|
|
foreach( t; thread_array )
|
|
t.start();
|
|
thread_joinAll();
|
|
sw.stop();
|
|
writeln( "Elapsed time for ", worker_count, " workers times ", yield_count, " yield() calls with threads = ",
|
|
sw.peek().msecs, "ms" );
|
|
}
|
|
int main()
|
|
{
|
|
fiber_test();
|
|
thread_test();
|
|
return 0;
|
|
}
|