Timeout Functions

namespace TimeoutFunctions.Workers
{
    using System;
    using System.Collections.Generic;
    using System.Threading;

    internal class TimeoutWorker : BaseWorker
    {
        Thread worker = null;

        public TimeoutWorker() {
            worker = new Thread(this.StartProcess);
        }

        public override bool Start(DataCarrier dataCarrier) {
            
            // Starting the thread
            worker.Start(dataCarrier);
            // blocking current thread until worker finishes or timeout detected
            bool success = worker.Join(dataCarrier.TimeOut);
            if (!success)
                ProcessTimeout();
            return success;
        }

        void StartProcess(object userState) {
            DataCarrier data = userState as DataCarrier;
            WaitCallback methodToExecute = data.MethodToExecute;
            base.ExecuteMethod(userState, methodToExecute);
        }

        void ProcessTimeout() {
            worker.Abort();
        }
    }
}