ThreadInfo.cs

Go to the documentation of this file.

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;

namespace DirectOutput.General
{
    public class ThreadInfo : IDisposable
    {
        #region IDisposable Member

        public void Dispose()
        {
            Dispose(true);
            GC.SuppressFinalize(this);
        }


        protected virtual void Dispose(bool disposing)
        {
            if (disposing)
            {
                // free managed resources

            }
            // free native resources if there are any.
            Thread = null;
        }

        #endregion




        private Queue<Exception> _Exceptions = new Queue<Exception>();
        public IList<Exception> Exceptions
        {
            get { return _Exceptions.ToList(); }
        }

        public void RecordException(Exception Exception)
        {
            _Exceptions.Enqueue(Exception);
            if (_Exceptions.Count > 30)
            {
                _Exceptions.Dequeue();
            }
        }


        public string HostName { get; set; }

        public Thread Thread { get; set; }

        public DateTime LastHeartBeat { get; private set; }

        public void HeartBeat()
        {
            LastHeartBeat = DateTime.Now;
            SetProcessorNumber();
        }

        private int _HeartBeatTimeOutMs=1000;

        public int HeartBeatTimeOutMs
        {
            get { return _HeartBeatTimeOutMs; }
            set { _HeartBeatTimeOutMs = value; }
        }
        

        public int ProcessorNumber
        {
            get;
            private set;
        }

        private bool GetCurrentProcessorNumberIsAvailable = false;
        private void SetProcessorNumber()
        {
            if (GetCurrentProcessorNumberIsAvailable)
            {
                ProcessorNumber = Kernel32Imports.GetCurrentProcessorNumber();
            }
        }



        public string ThreadName
        {
            get { return Thread.Name; }
        }

        public bool IsAlive
        {
            get
            {
                
                return Thread.IsAlive;
            }
        }

        public ThreadInfo(Thread Thread)
        {
            this.Thread = Thread;
            GetCurrentProcessorNumberIsAvailable = Kernel32Imports.GetCurrentProcessorNumberIsAvailable;
 
            HeartBeat();

        }

        public ThreadInfo()
            : this(Thread.CurrentThread)
        {

        }


        ~ThreadInfo()
        {
            Dispose(false);
        }


    }
}