Click here to Skip to main content
Click here to Skip to main content
Add your own
alternative version

Timeout Functions

, 11 Dec 2008
This article explains about executing a function within a time limit. Also includes a helper class which helps to implement timeout functions easily. This article deals with running multiple timeout processes each with time limit.
namespace TimeoutFunctions.Workers
{
    using System;
    using System.Collections.Generic;
    using System.Threading;

    internal class AsyncTimeoutWorker : BaseWorker
    {
        /// <summary>
        /// Fires when async process finishes or timedout
        /// </summary>
        public event EventHandler<AsyncProcessEventArgs> AsyncProcessCompleted = null;
        int asyncProcessCount = 0;

        /// <summary>
        /// Returns TRUE if any async processes are executing
        /// </summary>
        public bool IsAsyncProcessExecuting {
            get { return asyncProcessCount != 0; }
        }

        /// <summary>
        /// Gets number of asynchronous processes currently executing
        /// </summary>
        public int AsyncProcessCount {
            get { return asyncProcessCount; }
        }

        public override bool Start(DataCarrier dataCarrier) {
            this.IncrementAsyncProcessCount();
            return ThreadPool.QueueUserWorkItem(StartAsyncProcess, dataCarrier);
        }

        void StartAsyncProcess(object state) {
            
            DataCarrier data = state as DataCarrier;
            WaitCallback methodToExecute = data.MethodToExecute;
            Thread asyncWorker = new Thread(delegate(object obj)
            {
                base.ExecuteMethod(data.UserState, methodToExecute);
            });
            asyncWorker.IsBackground = true;
            asyncWorker.Start();
            bool success = asyncWorker.Join(data.TimeOut);
            this.DecrementAsyncProcessCount();
            AsyncProcessEventArgs args = new AsyncProcessEventArgs(data.UserState, success);
            if (!success)
                ProcessTimeout(asyncWorker, args, data.TimeOut);
            OnAsyncProcessCompleted(args);
        }

        void OnAsyncProcessCompleted(AsyncProcessEventArgs args) {
            if (AsyncProcessCompleted != null)
                AsyncProcessCompleted(this, args);
        }

        void ProcessTimeout(Thread thread, AsyncProcessEventArgs args, TimeSpan abortWait) {
            thread.Abort();
            // waiting for specified time to abort. Default is 1 second
            if (!thread.Join(abortWait)) {
                // thread won't end
                args.IsThreadRunning = true;
                args.AsyncWorker = thread;
            }
        }

        void IncrementAsyncProcessCount() {
            Interlocked.Increment(ref asyncProcessCount);
        }

        void DecrementAsyncProcessCount() {
            Interlocked.Decrement(ref asyncProcessCount);
        }
    }
}

By viewing downloads associated with this article you agree to the Terms of Service and the article's licence.

If a file you wish to view isn't highlighted, and is a text file (not binary), please let us know and we'll add colourisation support for it.

License

This article, along with any associated source code and files, is licensed under The Code Project Open License (CPOL)

About the Author

N a v a n e e t h
Software Developer ThoughtWorks
India India
Call me Navaneeth Some years ago--never mind how long precisely, I was doing programs with C and C++. When .NET came, I started with C#,ASP.NET and SQL Server.

| Advertise | Privacy | Mobile
Web01 | 2.8.140721.1 | Last Updated 11 Dec 2008
Article Copyright 2008 by N a v a n e e t h
Everything else Copyright © CodeProject, 1999-2014
Terms of Service
Layout: fixed | fluid