New Avoid Hang

avoidhang.cs

  internal class AvoidHang : IDisposable
    {
        private readonly SemaphoreSlim _semaphore = new System.Threading.SemaphoreSlim(1, 1);
        Stopwatch stopwatch = new Stopwatch();
        bool _started = true;
        public AvoidHang(int fast = 1000)
        {
            stopwatch.Start();

            (new Thread(() =>
            {
                while (_started)
                {
                    Thread.Sleep(fast);
                    try
                    {
                        if (_semaphore.CurrentCount == 0)
                            _semaphore.Release();
                    }
                    catch (Exception)
                    {
                        // ignored
                    }
                }
            })).Start();
        }


        public void Dispose()
        {
            _started = false;
            _semaphore.Dispose();
        }

        public void ToAvoidHang(Action action = null)
        {
            lock (this)
            {
                if (_semaphore.CurrentCount != 1) return;
                _semaphore.Wait();
                action?.Invoke();
            }
        }
    }