Ticket #596: thread_loop.d

import tango.core.Memory;
import tango.core.Thread;
import tango.stdc.stdio;


void threadFunc()
{
    char[] msg1 = "fiber yield:  %.*s\n\0".dup;
    char[] msg2 = "fiber resume: %.*s\n\0".dup;

    void dg()
    {
        printf( msg1.ptr, Thread.getThis().name );
        Fiber.yield();
        printf( msg2.ptr, Thread.getThis().name );
    }
    Fiber fiber = new Fiber( &dg );
    assert( fiber.state == Fiber.State.HOLD );

    Thread.sleep( 0.3 );
    fiber.call();
    assert( fiber.state == Fiber.State.HOLD );
    fiber.call();
    assert( fiber.state == Fiber.State.TERM );
    // allocate new thread to replace this one
    printf( "recycling: %.*s\n", Thread.getThis().name );
    Thread thread = new Thread( &threadFunc );
    thread.name = Thread.getThis().name;
    thread.start();
}


void main ()
{
    Thread.getThis().name = "main".dup;
    char[] n = "0".dup;
    for( size_t i = 0; i < 10; ++i )
    {
        printf( "creating %.*s\n", n );
        Thread thread = new Thread( &threadFunc );
        thread.name = n;
        thread.start();
        ++n[0];
        printf( "%p[%u]: %.*s\n", thread.name.ptr, thread.name.length, thread.name );
    }

    while( true )
    {
        printf( "collecting: %u\n", Thread.getAll().length );

        GC.collect();

        printf( "collected\n" );
        Thread.sleep( 1.0 );
    }
}