ThreadInfoList.cs

Go to the documentation of this file.

using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading;
using DirectOutput.General.Generic;

namespace DirectOutput.General
{
    public class ThreadInfoList:List<ThreadInfo>
    {

        private object ListUpdateLocker=new object();

        public void HeartBeat(object HostObject=null)
        {
            try
            {
                this[Thread.CurrentThread].HeartBeat();
            }
            catch (ArgumentException AE)
            {
                if (AE.ParamName == "Thread")
                {
                    ThreadInfo TI = new ThreadInfo(Thread.CurrentThread);
                    if (HostObject != null)
                    {
                        if (HostObject is INamedItem)
                        {
                            TI.HostName = ((INamedItem)HostObject).Name;
                        }
                        else
                        {
                            TI.HostName = HostObject.GetType().Name;
                        }
                    }
                    lock (ListUpdateLocker)
                    {
                        this.Add(TI);
                    }
                }
            }
        }

        public void HeartBeat(string HostObjectName)
        {
            try
            {
                this[Thread.CurrentThread].HeartBeat();
            }
            catch (ArgumentException AE)
            {
                if (AE.ParamName == "Thread")
                {
                    ThreadInfo TI = new ThreadInfo(Thread.CurrentThread);
                    if(!HostObjectName.IsNullOrWhiteSpace()) {
                        TI.HostName = HostObjectName;
                        
                    }
                    lock (ListUpdateLocker)
                    {
                        this.Add(TI);
                    }
                }
            }
        }

        public void RecordException(Exception Exception, object HostObject=null) {
            HeartBeat(HostObject);
            this[Thread.CurrentThread].RecordException(Exception);
        }

        public void ThreadTerminates()
        {
            if (this.Contains(Thread.CurrentThread))
            {
                lock (ListUpdateLocker)
                {
                    this.Remove(this[Thread.CurrentThread]);
                }
            }

        }


        public ThreadInfo this[Thread Thread]
        {
            get
            {
                if (Contains(Thread))
                {
                    return this.First(TI => TI.Thread == Thread);
                }
                throw new ArgumentException("The ThreadInfoList does not contain a ThreadInfo object for thread {0}.".Build(Thread.Name), "Thread");
            }
        }


        public bool Contains(Thread Thread)
        {
            return this.Any(TI=>TI.Thread==Thread);
        }

    }
}