SHJX_cod/SHJX.Service.Common/UserDelegate/Messager.cs

using System;
using System.Collections.Concurrent;

namespace SHJX.Service.Common.UserDelegate
{
    public static class Messager
    {
        private static readonly ConcurrentDictionary<string, Action<object>> Actions = new();

        /// <summary>
        /// 注册
        /// </summary>
        /// <param name="deleName"></param>
        /// <param name="action"></param>
        public static void Register(string deleName, Action<object> action)
        {
            if (!Actions.ContainsKey(deleName))
            {
                Actions.TryAdd(deleName, action);
            }
            Actions[deleName] = action;
        }

        /// <summary>
        /// 发送
        /// </summary>
        /// <param name="opKey"></param>
        /// <param name="arg"></param>
        public static void Send(string opKey, object arg = null)
        {
            if (Actions.TryGetValue(opKey, out var service))
            {
                service?.Invoke(arg);
            }
        }
    }
}