powerfun-unity/Assets/Scenes/Ride/Scripts/EventQueueManager.cs

using System.Collections;
using System.Collections.Generic;
using UnityEngine;
using System;

namespace Assets.Scenes.Ride.Scripts
{
    public class GameEvent { }

    public class EventQueueSystem : MonoSingleton<EventQueueSystem>
    {
        public delegate void EventDelegate<T>(T e) where T : GameEvent;

        private delegate void InternalEventDelegate(GameEvent e);

        private Dictionary<Type, InternalEventDelegate> delegates = new Dictionary<Type, InternalEventDelegate>();
        private Dictionary<Delegate, InternalEventDelegate> delegateLookup = new Dictionary<Delegate, InternalEventDelegate>();
        private Dictionary<InternalEventDelegate, Delegate> delegateLookOnce = new Dictionary<InternalEventDelegate, Delegate>();

        private Queue eventQueue = new Queue();

        public bool bLimitQueueProcessing = false;
        public float limitQueueTime = 1f;

        //注册侦听事件（持续）
        public static void AddListener<T>(EventDelegate<T> del) where T : GameEvent
        {
            Instance.AddDelegate(del);
        }

        //注册侦听事件（一次）
        public static void AddListenerOnce<T>(EventDelegate<T> del) where T : GameEvent
        {
            var result = Instance.AddDelegate(del);
            if (result != null)
                Instance.delegateLookOnce[result] = del;
        }

        //判定侦听事件是否存在
        public static bool HasListener<T>(EventDelegate<T> del) where T : GameEvent
        {
            return Instance.delegateLookup.ContainsKey(del);
        }

        //移除侦听事件
        public static void RemoveListener<T>(EventDelegate<T> del) where T : GameEvent
        {
            if (Instance == null)
                return;
            if (Instance.delegateLookup.TryGetValue(del, out InternalEventDelegate eventDelegate))
            {
                if (Instance.delegates.TryGetValue(typeof(T), out InternalEventDelegate temp))
                {
                    temp -= eventDelegate;
                    if (temp == null)
                        Instance.delegates.Remove(typeof(T));
                    else
                        Instance.delegates[typeof(T)] = temp;
                }
                Instance.delegateLookup.Remove(del);
            }
        }

        public static void RemoveAll()
        {
            if (Instance != null)
            {
                Instance.delegates.Clear();
                Instance.delegateLookup.Clear();
                Instance.delegateLookOnce.Clear();
            }
        }

        private InternalEventDelegate AddDelegate<T>(EventDelegate<T> del) where T : GameEvent
        {
            if (delegateLookup.ContainsKey(del))
                return null;
            void eventDelegate(GameEvent e) => del((T)e);
            delegateLookup[del] = eventDelegate;

            if (delegates.TryGetValue(typeof(T), out InternalEventDelegate temp))
                delegates[typeof(T)] = temp += eventDelegate;
            else
                delegates[typeof(T)] = eventDelegate;
            return eventDelegate;
        }

        //单个事件触发
        private static void TriggerEvent(GameEvent e)
        {
            var type = e.GetType();
            if (Instance.delegates.TryGetValue(type, out InternalEventDelegate eventDelegate))
            {
                eventDelegate.Invoke(e);
                //移除单一侦听
                foreach (InternalEventDelegate item in Instance.delegates[type].GetInvocationList())
                {
                    if (Instance.delegateLookOnce.TryGetValue(item, out Delegate temp))
                    {
                        Instance.delegates[type] -= item;
                        if (Instance.delegates[type] == null)
                            Instance.delegates.Remove(type);
                        Instance.delegateLookup.Remove(temp);
                        Instance.delegateLookOnce.Remove(item);
                    }
                }
            }
        }

        //外部调用的推入事件队列接口
        public static void QueueEvent(GameEvent e)
        {
            if (!Instance.delegates.ContainsKey(e.GetType()))
                return;
            Instance.eventQueue.Enqueue(e);
        }
        float timer = 0.0f;
        //事件队列触发处理
        void Update()
        {
            //float timer = 0.0f;
            //while (eventQueue.Count > 0)
            //{
            //    if (bLimitQueueProcessing)
            //        if (timer > limitQueueTime)
            //            return;
            //    var e = eventQueue.Dequeue() as GameEvent;
            //    TriggerEvent(e);
            //    if (bLimitQueueProcessing)
            //        timer += Time.deltaTime;
            //}
            timer += Time.deltaTime;
            while (timer >= 1 && eventQueue.Count > 0)
            {
                var e = eventQueue.Dequeue() as GameEvent;
                TriggerEvent(e);
                timer = 0;
            }
        }

        private void OnApplicationQuit()
        {
            RemoveAll();
            eventQueue.Clear();
        }
    }
}