Init

Assets/ThirdParty/UniFramework/UniEvent/Runtime/UniEvent.cs

@@ -0,0 +1,206 @@
+using System;
+using System.Collections;
+using System.Collections.Generic;
+using UnityEngine;
+
+namespace UniFramework.Event
+{
+	public static class UniEvent
+	{
+		private class PostWrapper
+		{
+			public int PostFrame;
+			public int EventID;
+			public IEventMessage Message;
+
+			public void OnRelease()
+			{
+				PostFrame = 0;
+				EventID = 0;
+				Message = null;
+			}
+		}
+
+		private static bool _isInitialize = false;
+		private static GameObject _driver = null;
+		private static readonly Dictionary<int, LinkedList<Action<IEventMessage>>> _listeners = new Dictionary<int, LinkedList<Action<IEventMessage>>>(1000);
+		private static readonly List<PostWrapper> _postingList = new List<PostWrapper>(1000);
+
+		/// <summary>
+		/// 初始化事件系统
+		/// </summary>
+		public static void Initalize()
+		{
+			if (_isInitialize)
+				throw new Exception($"{nameof(UniEvent)} is initialized !");
+
+			if (_isInitialize == false)
+			{
+				// 创建驱动器
+				_isInitialize = true;
+				_driver = new UnityEngine.GameObject($"[{nameof(UniEvent)}]");
+				_driver.AddComponent<UniEventDriver>();
+				UnityEngine.Object.DontDestroyOnLoad(_driver);
+				UniLogger.Log($"{nameof(UniEvent)} initalize !");
+			}
+		}
+
+		/// <summary>
+		/// 销毁事件系统
+		/// </summary>
+		public static void Destroy()
+		{
+			if (_isInitialize)
+			{
+				ClearAll();
+
+				_isInitialize = false;
+				if (_driver != null)
+					GameObject.Destroy(_driver);
+				UniLogger.Log($"{nameof(UniEvent)} destroy all !");
+			}
+		}
+
+		/// <summary>
+		/// 更新事件系统
+		/// </summary>
+		internal static void Update()
+		{
+			for (int i = _postingList.Count - 1; i >= 0; i--)
+			{
+				var wrapper = _postingList[i];
+				if (UnityEngine.Time.frameCount > wrapper.PostFrame)
+				{
+					SendMessage(wrapper.EventID, wrapper.Message);
+					_postingList.RemoveAt(i);
+				}
+			}
+		}
+
+		/// <summary>
+		/// 清空所有监听
+		/// </summary>
+		public static void ClearAll()
+		{
+			foreach (int eventId in _listeners.Keys)
+			{
+				_listeners[eventId].Clear();
+			}
+			_listeners.Clear();
+			_postingList.Clear();
+		}
+
+		/// <summary>
+		/// 添加监听
+		/// </summary>
+		public static void AddListener<TEvent>(System.Action<IEventMessage> listener) where TEvent : IEventMessage
+		{
+			System.Type eventType = typeof(TEvent);
+			int eventId = eventType.GetHashCode();
+			AddListener(eventId, listener);
+		}
+
+		/// <summary>
+		/// 添加监听
+		/// </summary>
+		public static void AddListener(System.Type eventType, System.Action<IEventMessage> listener)
+		{
+			int eventId = eventType.GetHashCode();
+			AddListener(eventId, listener);
+		}
+
+		/// <summary>
+		/// 添加监听
+		/// </summary>
+		public static void AddListener(int eventId, System.Action<IEventMessage> listener)
+		{
+			if (_listeners.ContainsKey(eventId) == false)
+				_listeners.Add(eventId, new LinkedList<Action<IEventMessage>>());
+			if (_listeners[eventId].Contains(listener) == false)
+				_listeners[eventId].AddLast(listener);
+		}
+
+
+		/// <summary>
+		/// 移除监听
+		/// </summary>
+		public static void RemoveListener<TEvent>(System.Action<IEventMessage> listener) where TEvent : IEventMessage
+		{
+			System.Type eventType = typeof(TEvent);
+			int eventId = eventType.GetHashCode();
+			RemoveListener(eventId, listener);
+		}
+
+		/// <summary>
+		/// 移除监听
+		/// </summary>
+		public static void RemoveListener(System.Type eventType, System.Action<IEventMessage> listener)
+		{
+			int eventId = eventType.GetHashCode();
+			RemoveListener(eventId, listener);
+		}
+
+		/// <summary>
+		/// 移除监听
+		/// </summary>
+		public static void RemoveListener(int eventId, System.Action<IEventMessage> listener)
+		{
+			if (_listeners.ContainsKey(eventId))
+			{
+				if (_listeners[eventId].Contains(listener))
+					_listeners[eventId].Remove(listener);
+			}
+		}
+
+
+		/// <summary>
+		/// 实时广播事件
+		/// </summary>
+		public static void SendMessage(IEventMessage message)
+		{
+			int eventId = message.GetType().GetHashCode();
+			SendMessage(eventId, message);
+		}
+
+		/// <summary>
+		/// 实时广播事件
+		/// </summary>
+		public static void SendMessage(int eventId, IEventMessage message)
+		{
+			if (_listeners.ContainsKey(eventId) == false)
+				return;
+
+			LinkedList<Action<IEventMessage>> listeners = _listeners[eventId];
+			if (listeners.Count > 0)
+			{
+				var currentNode = listeners.Last;
+				while (currentNode != null)
+				{
+					currentNode.Value.Invoke(message);
+					currentNode = currentNode.Previous;
+				}
+			}
+		}
+
+		/// <summary>
+		/// 延迟广播事件
+		/// </summary>
+		public static void PostMessage(IEventMessage message)
+		{
+			int eventId = message.GetType().GetHashCode();
+			PostMessage(eventId, message);
+		}
+
+		/// <summary>
+		/// 延迟广播事件
+		/// </summary>
+		public static void PostMessage(int eventId, IEventMessage message)
+		{
+			var wrapper = new PostWrapper();
+			wrapper.PostFrame = UnityEngine.Time.frameCount;
+			wrapper.EventID = eventId;
+			wrapper.Message = message;
+			_postingList.Add(wrapper);
+		}
+	}
+}