Generic Wrapper for Easy Multithreaded Programming


using Microsoft.VisualBasic;
using System;
using System.Collections;
using System.Collections.Generic;
using System.Data;
using System.Diagnostics;
using Asynchronous = SIGLR.Async.GenericWrapper;

internal class Worker2 : Asynchronous.Worker.WorkerBase<Worker2Input, Worker2Progress, Worker2Result>
{

    #region "Fields"

    private Asynchronous.AsyncManager<int, SubWorker1Result> withEventsField_aAsyncManagerForSubWorker;
    private Asynchronous.AsyncManager<int, SubWorker1Result> aAsyncManagerForSubWorker
    {
        get { return withEventsField_aAsyncManagerForSubWorker; }
        set
        {
            if (withEventsField_aAsyncManagerForSubWorker != null)
            {
                withEventsField_aAsyncManagerForSubWorker.WorkerDone -= aAsyncManagerForSubWorker_WorkerDone;
            }
            withEventsField_aAsyncManagerForSubWorker = value;
            if (withEventsField_aAsyncManagerForSubWorker != null)
            {
                withEventsField_aAsyncManagerForSubWorker.WorkerDone += aAsyncManagerForSubWorker_WorkerDone;
            }
        }

    }

    private Worker2Progress progresData;
    #endregion

    #region "Constructor"


    public Worker2(Worker2Input inputParams)
        : base(inputParams)
    {

    }

    #endregion

    #region "Subs and Functions"

    protected override Worker2Result DoWork(Worker2Input inputParams)
    {

        Worker2Result result = new Worker2Result();
        progresData = new Worker2Progress();

        int number = 0;

        aAsyncManagerForSubWorker = new Asynchronous.AsyncManager<int, SubWorker1Result>("Id3", new SubWorker1(new SubWorker1Input("Enfant3", 100)));

        try
        {
            aAsyncManagerForSubWorker.StartWorker(base.IsAsynchronous);

            while (!base.InterruptionRequested)
            {
                number = number + 1;
                progresData.Number = number;
                progresData.Status = number.ToString();
                System.Threading.Thread.Sleep(150);

                base.WorkerProgressSignal(progresData);

                //To test an exception, uncomment the following line
                //Throw New Exception("This is an exception from the worker 2")

                if (number > 40)
                {
                    break; // TODO: might not be correct. Was : Exit Do
                }
            }

            if (base.InterruptionRequested)
            {
                result.ResultText = "Interrupted";
                aAsyncManagerForSubWorker_WorkerDone(this, aAsyncManagerForSubWorker.StopWorkerAndWait());
            }
            else
            {
                result.ResultText = "Finished";
            }

            if (aAsyncManagerForSubWorker.IsWorkerBusy)
            {
                aAsyncManagerForSubWorker_WorkerDone(this, aAsyncManagerForSubWorker.WaitForWorker());
            }

        }
        catch (Exception ex)
        {
            if (aAsyncManagerForSubWorker.IsWorkerBusy)
            {
                aAsyncManagerForSubWorker_WorkerDone(this, aAsyncManagerForSubWorker.StopWorkerAndWait());
            }
            throw;
        }

        return result;

    }

    #endregion

    #region "SubWorker 1 Events"


    private void aAsyncManagerForSubWorker_WorkerDone(object sender, Asynchronous.Events.WorkerDoneEventArgs<SubWorker1Result> e)
    {
        if (e.Exception == null)
        {
            if (e.Interrupted)
            {
                progresData.SubWorker1Status = e.Result.ResultText;
            }
            else
            {
                progresData.SubWorker1Status = e.Result.ResultText + " Some total: " + e.Result.SomeTotal;
            }
        }
        else
        {
            progresData.SubWorker1Status = "Exception " + e.Identity + ":" + e.Exception.ToString();
        }

        base.WorkerProgressSignal(progresData);

    }

    #endregion

}