Multithreading.Scheduler

The library gives you a control over the lifecycle of threds. You can create a dedicated threads for a particular work. This means that the library is suitable for applications which need to do a background processing. It is a tradeoff. You gain performance boost because the context switching is removed, like the.NET thread pool does, but this allocates resources which could not be reused.

Usage

class Program
{
    static void Main(string[] args)
    {
        AtomicInteger state = new AtomicInteger();
        string poolName = "This name is assigned to the current Thread.Name";
        int numberOfThreadsAvailableForThePool = 5;

        WorkPool pool = new WorkPool(poolName, numberOfThreadsAvailableForThePool);
        for (int i = 0; i < numberOfThreadsAvailableForThePool; i++)
        {
            pool.AddWork(new IncrementByOne(state));
        }
        pool.StartCrawlers();

        Console.WriteLine("Press enter to exit...");
        Console.ReadLine();

        pool.Stop();
    }
}

public class IncrementByOne : IWork
{
    private readonly AtomicInteger state;

    public IncrementByOne(AtomicInteger state)
    {
        this.state = state;
    }

    public DateTime ScheduledStart { get; set; }

    public void Start()
    {
        state.Increment();
    }

    public void Stop()
    {
        //  Do cleanup here.
    }
}

public class AtomicInteger
{
    private int currentValue;

    public void Increment()
    {
        Interlocked.Increment(ref currentValue);
    }
}