Unity子线程与主线程交互二(事件监听)

Unity  Api无法从子线程访问, 但有些操作(例:IO存取文件)又必须子线程运行, 故实现在子线程做耗时操作, 完成后通知主线程更新状态

以事件监听方式完成交互,规避无限回调地狱

如何注册丶调用事件:

        var event1 = "event1";var event2 = "event2";var thread = Unity.Threading.EasyThread.GetInstance();//注册主线程监听thread.mainRemote.On(event1, () =>{//Main Thread Event//...//移除监听thread.mainRemote.Remove(event1);});thread.mainRemote.On<string>(event2, (data) =>{//Main Thread Event//...//移除监听thread.mainRemote.Remove(event2);});//注册子线程监听thread.childRemote.Once(event2, () =>{//Child Thread Event//...//推送事件到主线程//参数: 参数个数丶类型必须与监听者一致thread.mainRemote.Send(event1);thread.mainRemote.Send(event2, "ChildTread To MainThread Event");});//推送子线程事件,激活子线程监听方法thread.childRemote.Send(event2);

代码类:

namespace Unity.Threading
{using System;using System.Threading;using System.Collections;using System.Collections.Generic;using UnityEngine;using SystemThread = System.Threading.Thread;using System.Reflection;public delegate void Callback(params object[] args);//监听者internal class Listener{public string eventName;public string funcname;public object target;public MethodInfo targetMethod;public int count;}//数据包(事件数据)internal class EventData{public Listener listener;public string eventName;public object[] args;}//事件系统public class EventMgr{//监听者列表private Dictionary<string, List<Listener>> events = new Dictionary<string, List<Listener>>();//事件数据(缓冲列表)private LinkedList<EventData> firedDatas = new LinkedList<EventData>();//调用列表(如果直接使用firedDatas列表,在完成所有调用前,将会阻塞整个事件系统)private LinkedList<EventData> doingDatas = new LinkedList<EventData>();//暂停事件调用?public bool pause = false;//注册一个事件监听, 默认不取消监听public void On(string event_name, Callback handler){On(event_name, handler.Target, handler.Method.Name);}public void On(string event_name, Action handler){On(event_name, handler.Target, handler.Method.Name);}public void On<T>(string event_name, Action<T> handler){On(event_name, handler.Target, handler.Method.Name);}public void On<T1, T2>(string event_name, Action<T1, T2> handler){On(event_name, handler.Target, handler.Method.Name);}public void On<T1, T2, T3>(string event_name, Action<T1, T2, T3> handler){On(event_name, handler.Target, handler.Method.Name);}public void On(string event_name, object target, string funcname){Register(events, event_name, target, funcname, -1);}//注册一个事件监听, 完成一次调用后,取消监听//如果多个线程向一个once监听者发送消息, once可能被调用多次(缓存消息和调用事件影响/请自行处理监听者或尝试修改代码)public void Once(string event_name, Callback handler){Once(event_name, handler.Target, handler.Method.Name);}public void Once(string event_name, Action handler){Once(event_name, handler.Target, handler.Method.Name);}public void Once<T>(string event_name, Action<T> handler){Once(event_name, handler.Target, handler.Method.Name);}public void Once<T1, T2>(string event_name, Action<T1, T2> handler){Once(event_name, handler.Target, handler.Method.Name);}public void Once<T1, T2, T3>(string event_name, Action<T1, T2, T3> handler){Once(event_name, handler.Target, handler.Method.Name);}public void Once(string event_name, object target, string funcname){Register(events, event_name, target, funcname, 1);}//移除事件监听public void Remove(object target){Unregister(events, target);}public void Remove(string event_name){Unregister(events, event_name);}public void Remove(string event_name, object target, string funcname){Unregister(events, event_name, target, funcname);}//清空事件监听丶事件数据public void Clear(){events.Clear();ClearDatas();}public void ClearDatas(){MonitorEnter(events);firedDatas.Clear();MonitorExit(events);doingDatas.Clear();}//向此事件系统,发送一条数据(事件数据)//如果多个线程向一个once监听者发送消息, once可能被调用多次(缓存消息和调用事件影响/请自行处理监听者或尝试修改代码)public void Send(string event_name, params object[] args){Fire(events, firedDatas, event_name, args);}//事件调用(外部调用)public void Process(){MonitorEnter(events);if (firedDatas.Count > 0){var iter = firedDatas.GetEnumerator();while (iter.MoveNext()){doingDatas.AddLast(iter.Current);}firedDatas.Clear();}MonitorExit(events);while (doingDatas.Count > 0 && !pause){EventData data = doingDatas.First.Value;doingDatas.RemoveFirst();try{Listener listener = data.listener;listener.targetMethod.Invoke(listener.target, data.args);if (listener.count > 0)listener.count--;if (listener.count == 0){Unregister(events, listener.eventName, listener.target, listener.funcname);}}catch (Exception e){Debug.LogError("Event::processOutEvents: event="+ data.listener.targetMethod.DeclaringType.FullName+ "::" + data.listener.funcname + "\n"+ e.ToString());}}}static void Register(Dictionary<string, List<Listener>> events, string event_name, object target, string funcname, int count){Unregister(events, event_name, target, funcname);Listener listener = new Listener(){eventName = event_name,target = target,funcname = funcname,count = count};listener.targetMethod = target.GetType().GetMethod(funcname, BindingFlags.Instance | BindingFlags.Static | BindingFlags.Public | BindingFlags.NonPublic);if (listener.targetMethod == null){Debug.LogError("Event::register: " + target + "not found method[" + funcname + "]");return;}MonitorEnter(events);List<Listener> lst = null;if (!events.TryGetValue(event_name, out lst)){lst = new List<Listener>();events.Add(event_name, lst);}lst.Add(listener);Debug.Log("Event::register: event(" + event_name + ")!");MonitorExit(events);}static void Unregister(Dictionary<string, List<Listener>> events, string event_name, object target, string funcname){MonitorEnter(events);List<Listener> lst;if (!events.TryGetValue(event_name, out lst)){MonitorExit(events);return;}// 从后往前遍历，以避免中途删除的问题for (int i = lst.Count - 1; i >= 0; i--){if (target == lst[i].target){Debug.Log("Event::deregister: event(" + lst[i].target + ":" + lst[i].funcname + ")!");lst.RemoveAt(i);}}MonitorExit(events);}static void Unregister(Dictionary<string, List<Listener>> events, object target){if (target == null){Debug.LogWarning("Attempt remove NULL object  all event");return;}MonitorEnter(events);var iter = events.GetEnumerator();while (iter.MoveNext()){List<Listener> lst = iter.Current.Value;// 从后往前遍历，以避免中途删除的问题for (int i = lst.Count - 1; i >= 0; i--){if (target == lst[i].target){Debug.Log("Event::deregister: event(" + lst[i].target + ":" + lst[i].funcname + ")!");lst.RemoveAt(i);}}}MonitorExit(events);}static void Unregister(Dictionary<string, List<Listener>> events, string event_name){MonitorEnter(events);var iter = events.GetEnumerator();while (iter.MoveNext()){List<Listener> lst = iter.Current.Value;// 从后往前遍历，以避免中途删除的问题for (int i = lst.Count - 1; i >= 0; i--){if (event_name == lst[i].eventName){Debug.Log("Event::deregister: event(" + lst[i].target + ":" + lst[i].funcname + ")!");lst.RemoveAt(i);}}}MonitorExit(events);}static void Fire(Dictionary<string, List<Listener>> events, LinkedList<EventData> cacheDatas, string event_name, params object[] args){MonitorEnter(events);List<Listener> lst = null;if (!events.TryGetValue(event_name, out lst)){Debug.Log("Event::fire: event(" + event_name + ") not found!");MonitorExit(events);return;}foreach (var listener in lst){cacheDatas.AddLast(new EventData(){listener = listener,eventName = event_name,args = args});}MonitorExit(events);}//锁对象(保证线程安全/在上一次未MonitorExit前, 无法对此对象MonitorEnter)static void MonitorEnter(object obj){Monitor.Enter(obj);}static void MonitorExit(object obj){Monitor.Exit(obj);}}public class EasyThread : MonoBehaviour{//主线程IDprivate static readonly int mainThreadId = SystemThread.CurrentThread.ManagedThreadId;private static EasyThread instance = null;public EventMgr mainRemote { get; } = new EventMgr();public EventMgr childRemote { get; } = new EventMgr();//线程对象/状态private SystemThread thread;private bool runing;public static EasyThread GetInstance(){if (instance == null){var obj = new GameObject("[UnityThread]");DontDestroyOnLoad(obj);instance = obj.AddComponent<EasyThread>();}return instance;}public static EasyThread NewInstance(string name = null){var obj = new GameObject(name ?? ("[UnityThread" + UnityEngine.Random.Range(0, int.MaxValue) + "]"));return obj.AddComponent<EasyThread>();}void Awake(){StartThread();}void FixedUpdate(){mainRemote.Process();}void OnDestroy(){runing = false;mainRemote.Clear();childRemote.Clear();}public void StartThread(){StopThread();MonitorEnter();if (thread == null || !thread.IsAlive || !runing){runing = true;thread = new SystemThread(new ThreadStart(() =>{while (runing && this != null){childRemote.Process();Thread.Sleep(20);}}));thread.IsBackground = true;thread.Start();}MonitorExit();}public void StopThread(){MonitorEnter();runing = false;if (thread != null && thread.IsAlive){thread.Abort();}thread = null;MonitorExit();}void MonitorEnter() { Monitor.Enter(this); }void MonitorExit() { Monitor.Exit(this); }}
}