Re: Fibers

[Flamencofantasy via Digitalmars-d-learn]

if (++count >= fibs.length)...


On Wednesday, 17 September 2014 at 10:00:49 UTC, Andrew Edwards
wrote:

The script below is borrowed form a unit test in core.thread and modified slightly. If fails with "segmentation fault: 11" but I'm not sure why.

Basically what I'm trying to do is to transact on every file in give directory at the same time exact time.

In this exam, I'm removing the file/directory but that's just a test to see if I could get it to work.

Guidance is requested and appreciated.

Thanks,
Andrew

---------------------------------
import core.thread;
import std.process;
import std.file;
import std.stdio;

void main(string[] args)
{
        auto f = args[1];
        deleteWithFibers(f);
}

class TestFiber : Fiber
{
        string file;

        this(string file)
        {
                this.file = file;
                super(&run);
        }

        void run()
        {
                while (file.exists) {
                        if (file.isFile)
                                file.remove;
                        else if (file.isDir)
                                file.rmdir;
                        Fiber.yield();
                }
        }
}

void deleteWithFibers(string dir)
{
        auto fibs = new TestFiber[100];
        
        int count = 0;
        foreach (entry; dirEntries(dir, SpanMode.depth))
        {
                fibs[count] = new TestFiber(entry);

                if (++count > fibs.length)
                        fibs.length *= 2;
        }

        fibs.length = count+1;

        bool cont;
        do {
                cont = false;
                foreach(fib; fibs) {
                        if (fib.state == Fiber.State.HOLD)
                        {
                                fib.call();
                                cont |= fib.state != Fiber.State.TERM;
                        }
                }
        } while (cont);
}