using System.Diagnostics;
using NewLife.Log;

namespace NewLife.Threading;

/// <summary>线程池助手</summary>
public class ThreadPoolX : DisposeBase
{
    #region 全局线程池助手
    static ThreadPoolX()
    {
        // 在这个同步异步大量混合使用的时代，需要更多的初始线程来屏蔽各种对TPL的不合理使用
        ThreadPool.GetMinThreads(out var wt, out var io);

        // 目标最小线程数：min(64, 4 * 核数)。避免过高导致切换开销，同时覆盖启动期大批并发初始化
        var cores = Environment.ProcessorCount;
        var target = Math.Min(64, cores * 4);
        if (wt < target || io < target)
        {
            if (wt < target) wt = target;
            if (io < target) io = target;
            ThreadPool.SetMinThreads(wt, io);
        }

#if NET7_0_OR_GREATER
        // 线程池最大延迟，超过这个延迟后，线程池会增加线程数。@一线码农
        AppContext.SetData("System.Threading.ThreadPool.Blocking.MaxDelayMs", 50);
#endif
    }

    /// <summary>初始化线程池
    /// </summary>
    public static void Init() { }

    /// <summary>带异常处理的线程池任务调度，不允许异常抛出，以免造成应用程序退出，同时不会捕获上下文</summary>
    /// <param name="callback"></param>
    [DebuggerHidden]
    public static void QueueUserWorkItem(Action callback)
    {
        if (callback == null) return;

        ThreadPool.UnsafeQueueUserWorkItem(s =>
        {
            try
            {
                callback();
            }
            catch (Exception ex)
            {
                XTrace.WriteException(ex);
            }
        }, null);

        //Instance.QueueWorkItem(callback);
    }

    /// <summary>带异常处理的线程池任务调度，不允许异常抛出，以免造成应用程序退出，同时不会捕获上下文</summary>
    /// <param name="callback"></param>
    /// <param name="state"></param>
    [DebuggerHidden]
    public static void QueueUserWorkItem<T>(Action<T> callback, T state)
    {
        if (callback == null) return;

        ThreadPool.UnsafeQueueUserWorkItem(s =>
        {
            try
            {
                callback(state);
            }
            catch (Exception ex)
            {
                XTrace.WriteException(ex);
            }
        }, null);

        //Instance.QueueWorkItem(() => callback(state));
    }
    #endregion
}