Unity子线程与主线程交互(委托方式)

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

事件监听方式, 规避回调地狱:https://blog.csdn.net/qq_34987964/article/details/107318813

using System;
using System.Collections;
using System.Collections.Generic;
using System.Threading;
using UnityEngine;/// <summary>
/// 子线程与主线程交互(委托实现)
/// </summary>
public class Loom : MonoBehaviour
{private static Loom _instance = null;//单例模式(此方法只能在主线程调用)public static void Instance(){if (_instance == null){var obj = new GameObject("Loom");XLuaManager.DontDestroyOnLoad(obj);obj.AddComponent<Loom>();}}//委托队列private Queue<Action> asyncQueue = new Queue<Action>();private Queue<Action> mainQueue = new Queue<Action>();//线程对象private Thread thread = null;//主线程每次Update执行Function数量private static int doUpdate = 5;void Awake(){if (_instance != null){DestroyImmediate(gameObject);return;}_instance = this;ThreadStart();}void Update(){DoFunction();}//执行Action(根据线程判断对应的方法)private void DoFunction(){if (Thread.CurrentThread == thread){if (asyncQueue.Count > 0){var func = asyncQueue.Dequeue();func();}}else{if (mainQueue.Count > 0){int number = doUpdate;do{var func = mainQueue.Dequeue();func();number--;} while (number > 0 && mainQueue.Count > 0);}}}public void AsyncFunction(Action action){asyncQueue.Enqueue(action);}public void MainFunction(Action action){mainQueue.Enqueue(action);}//停止线程public void ThreadStop(){if (thread != null && thread.IsAlive){thread.Abort();thread = null;DestroyImmediate(gameObject);}}void ThreadStart(){ThreadStop();thread = new Thread(new ThreadStart(ThreadDelegate));thread.IsBackground = true;thread.Start();}void ThreadDelegate(){while (this != null){DoFunction();}Debug.Log("Thread Done");}void OnDestroy(){Dispose();}public static void InvokeAsync(Action action){if (_instance == null){throw new Exception("未实例化Loom对象");}lock (_instance){_instance.AsyncFunction(action);}}public static void InvokeMain(Action action){if (_instance == null){throw new Exception("未实例化Loom对象");}lock (_instance){_instance.MainFunction(action);}}public static bool IsAlive(){if (_instance != null){lock (_instance){return _instance.asyncQueue.Count > 0 || _instance.mainQueue.Count > 0;}}return false;}public static void Dispose(){if (_instance != null){lock (_instance){_instance.asyncQueue.Clear();_instance.mainQueue.Clear();_instance.ThreadStop();Destroy(_instance.gameObject);_instance = null;}}}
}

Unity子线程与主线程交互(委托方式)相关推荐

Qt自定义事件实现及子线程向主线程传送事件消息
近期在又一次学习Qt的时候,由于要涉及到子线程与主线程传递消息,所以便琢磨了一下.顺便把有用的记录下来,方便自己以后查询及各位同仁的參考! 特此声明,本篇博文主要讲述有用的,也就是直接说明怎么实现,就 ...
android Handler Message传递参数，handler子线程和主线程通讯
创建Handler private Handler handler = new Handler() {@Overridepublic void handleMessage(Message msg) { ...
Python 多个线程按先后顺序执行，并保持各子线程和主线程的通信
Python 多个线程按先后顺序执行,并保持各子线程和主线程的通信摘要最近有个项目使用pyqt5写的界面,界面展示部分作为项目的主线程,另外通过调用Thread,传入不同的参数又设置了五个子线程, ...
【EventBus】事件通信框架 ( 发送事件 | 判断发布线程是否是主线程 | 子线程切换主线程 | 主线程切换子线程 )
文章目录前言一.根据不同的线程模式进行不同的线程切换操作二.完整代码示例前言发布线程发布事件之后 , 消息中心需要转发这些事件 , 并执行相应的订阅方法 ; 在转发的过程中 , 需要针对订阅 ...
Android笔记（三十一）Android中线程之间的通信（三）子线程给主线程发送消息...
先看简单示例:点击按钮,2s之后,TextView改变内容. package cn.lixyz.handlertest;import android.app.Activity; import andr ...
19 Handler 子线程向主线程发送信息
案例一 Message创建三种方法: package com.example.day19_handler_demo1;import android.os.Bundle; import android. ...
子线程和主线程的关系
运行附录中test.py中的代码, 主线程和子线程啥关系? 首先多个子线程在运行的时候. 然后终端输入ps -ef|grep python 会发现: 虽然我们的脚本中是两个子线程,但是终端的监控中只能 ...
MFC子线程访问主线程对话框程序的控件对象
最近在使用 VC 开发软件时需要用到多线程同步来解决开发过程中遇到的问题.本来以为只要象控制台程序一样,在主线程创建子线程,并设置好相应的对象事件就能解决问题,但是等到真正做起来,才在实践中发现原来事 ...
QT子线程与主线程的信号槽通信
最近用QT做一个服务器,众所周知,QT的主线程必须保持畅通,才能刷新UI.所以,网络通信端采用新开线程的方式.在涉及到使用子线程更新Ui上的控件时遇到了点儿麻烦.网上提供了很多同一线程不同类间采用信号 ...

Unity子线程与主线程交互(委托方式)

Unity子线程与主线程交互(委托方式)相关推荐

最新文章

热门文章