c# – 检测/诊断线程饥饿

根据Sinatr的评论,我在ThreadPool.SetMinThreads和TaskCreationOptions.LongRunning上做了一些阅读,包括对 When to use TaskCreationOptions.LongRunning?的回答

将MinThreads设置为更高的默认值会对我的情况产生巨大影响.我创建了一个简单的后台进程,以查看ThreadPool中的可用线程在测试运行过程中是否发生了显着变化,并且超过了MinThreads值(它是).

这是我用来诊断的一些代码.这不适用于生产用途,此处显示的线程使用情况报告只会在最初增加时才会引起注意.另请注意,Timer过去需要一个线程,因此还需要等待一个可用的线程.

静态变量：

private static Timer _timer;
    private static int _lastActiveThreads;
    private static int _lastAvailableThreads;
    private static int _maxThreads;
    private static int _minThreads;

在启动时运行：

int completionPortThreads;

    ThreadPool.GetMaxThreads(out _maxThreads,out completionPortThreads);
    ThreadPool.GetMinThreads(out _minThreads,out completionPortThreads);

    _timer = new Timer
    {
        AutoReset = true,Interval = 500,};

    _timer.Elapsed += TimerElasped;
    _timer.Start();

经过的方法：

private static void TimerElasped(object sender,ElapsedEventArgs e)
    {
        int minWorkerThreads;
        int availWorkerThreads;
        int completionPortThreads;

        ThreadPool.GetMinThreads(out minWorkerThreads,out completionPortThreads);
        ThreadPool.GetAvailableThreads(out availWorkerThreads,out completionPortThreads);

        var activeThreads = _maxThreads - availWorkerThreads;

        if (availWorkerThreads != _lastAvailableThreads)
        {
            _lastAvailableThreads = availWorkerThreads;
            if (activeThreads > _lastActiveThreads)
            {
                _lastActiveThreads = activeThreads;
                Logger.Log($"+++++ Active Threads is now: {activeThreads}");

                if (activeThreads > _minThreads)
                {
                    var diff = activeThreads - _minThreads;
                    Logger.Log($"+++++ Active threads is now {activeThreads},which is {diff} more than minThread value of {_minThreads}.  This may be causing delays.");
                }
            }
        }
    }