zoukankan      html  css  js  c++  java
  • 关于Unity中协程、多线程、线程锁、www网络类的使用

    协程

    我们要下载一张图片,加载一个资源,这个时候一定不是一下子就加载好的,或者说我们不一定要等它下载好了才进行其他操作,如果那样的话我就就卡在了下载图片那个地方,傻住了。我们希望我们只要一启动加载的命令,回来的时候主线程能够继续进行下去。

    我们可以启动一个协程去下载,主进程依然在运行。有点类似多线程,不同的是,实际上它还是在一个线程里面,所以我们是在主线程中开启一段逻辑来进行处理,来协同当前程序的执行,还是在主线程里面。

    1:在主进程中开启另外一段逻辑处理,来协同当前程序的执行,但与多线程不同都是在主线程里面执行的,而且原来的进程依然进行下去,

    2:通过StartCoroutine方法来启动一个协程,StartCoroutine是MonoBehaviour的一个方法,该方法可以启动一个协程,每个协程都有一个入口函数,协程必须要是一个IEnumerator 作为返回值的方法(入口函数);

    3:协同程序可以使用yield 关键字来中断协同程序;

    4:协程也可以启动一个协程;

    5:WaitForSeconds(): 等待多长时间后中断协程;

    协程实例

    1.创建Unity项目和文件目录,保存场景

    2.创建一个空节点game,再创建一个脚本game挂载在gamej节点下

     打开game脚本

    using System.Collections;
    using System.Collections.Generic;
    using UnityEngine;
    
    public class game : MonoBehaviour {
    
        private int level=3;
        // Use this for initialization
        void Start () {
            //启动一个协程,必须是继承自MonoBehaviour才能使用
            this.StartCoroutine(this.con_entry());
            
            //主线程依然在执行
            //...
        }
    
        //协程和主线程是在同一个线程里面的,不会有什么线程切换
        //协程的入口函数
        IEnumerator con_entry(){
            //协程的代码
            Debug.Log("con_entry run!!");
            Debug.Log("level:" + this.level);//也能够拿到this的变量
            this.StartCoroutine(this.con_other());//再开启一个协程con_other
            //end
    
    
            //使用yield中断协程程序,就是让它停下来
            yield return null;
    
    
            //协程结束以后的代码,比如去网上捞一个什么东西,下载图片之类的,捞完之后的操作
            //end
        }
    
        IEnumerator con_other()
        {
            Debug.Log("con_other");
            this.StartCoroutine(this.con_entry_params(3));//再开启一个协程con_entry_params,且传递参数
            
            yield return null;
        }
    
        IEnumerator con_entry_params(int a)
        {
            Debug.Log("con_entry_params: " + a);
    
            yield return new WaitForSeconds(3);//设置3秒中之后才中断协程
    
            Debug.Log("after WaitForSeconds send");// 处理协程结束的逻辑
        }
    
    
        // Update is called once per frame
        void Update () {
            
        }
    }

     3.运行结果

    多线程

    我们的操作系统是多任务操作系统,实际上只有一个cpu是怎样做到多任务的呢?就是通过线程切换来完成的,每个任务可以看成是一个进程或者线程,多任务多线程就是让cpu在线程里面不断地切换,如果切换的频率足够快,人们就会认为多个任务是同时在执行的。

    例子:一边编辑文本,一边播MP3,播MP3也就是解码一段3秒钟的音乐,只需要消耗CPU0.01秒,也就是说剩下的2.99秒CPU都是空闲的,所以才提出多线程的解决方案,充分利用CPU资源。

    游戏一般都是有一个主线程,是处理游戏的主要事情,但是有些事情我们不希望在主线程里面处理,

    比如有一项工作特别耗时,下载一个资源文件,如果把它放在主线程里面等待下载完成的那段时间就卡住了,游戏就卡住了,要等10分钟下载好后主线程才会恢复,这是无法忍受的。

    于是我们的做法就是开启另外一个线程,然后再去下载,下载过程中通知主线程当前下载的量,主线程继续执行并更新下载的数据。

    多线程的好处是:1.现在的手机电脑的CPU都是多个核的,每个核是可以独立调度一个线程的,本来游戏只在一个核上运行,如果有了一个复杂的计算,把它放在另外一个线程里面,

             如果是运行在双核上面,那就有两个核来运行游戏,一个核来跑主线程,一个核来跑复杂的运算,这样子,基本上CPU的利用率就能上来,就能帮助我们快速处理复杂运算,这个叫做多核优化。

            2.不至于卡死主线程,能够让主线程获得一个更好的处理方式和更好的用户体验

            3.CPU有多个核,有几个核就可以调度几个线程,比如双核的就可以一次性调度两个线程主线程在跑,复杂线程也在跑,都不耽误。

    1: using System.Thread;

    2: 创建一个线程: Thread r = new Thread(callback);  r.start(); 启动运行线程;

    3: 线程回掉函数 void run() {}

    4: 多个线程访问同一个数据的时候,会发生”冲突”,需要线程安全的方式来访问;

    5: 线程锁是在访问公共数据的时候,先去获得这个锁,没有获得锁的线程将会被挂起,指导这个锁被释放。

    6: public static Object  o = new Object(); lock(o) {线程安全的执行代码};

    7: 线程休眠: Thread.Sleep(单位为ms);

    8: 多线程之间要避免死锁;

    多线程案例

    1.创建Unity项目和文件目录,保存场景

    2.创建一个空节点game,再创建一个脚本game挂载在gamej节点下

     打开game脚本

    using System.Collections;
    using System.Collections.Generic;
    using UnityEngine;
    using System.Threading;//多线程要用到的库,多线程对象所在的名字空间
    
    public class game : MonoBehaviour {
    
    
        // Use this for initialization
        void Start () {
          
            //创建一个线程t1,关联入口函数
            Thread t1 = new Thread(this.thread_run);//不是像协程那样直接运行
            t1.Start();//这里才开始执行,开启线程
    
            //再创建一个线程t2
            Thread t2 = new Thread(this.thread_run2);
            t2.Start();
    
        }
    
        //线程t1的入口函数
        void thread_run(){
            int i = 0;
            while (i < 10){//打印10次
                Debug.Log("thread_run");
                i++;
                Thread.Sleep(3000);//让线程休息3秒钟,有点像定时器,里面参数是毫秒为单位的
            }
        }
    
        //线程t2的入口函数
        void thread_run2(){
            int i = 0;
            while (i < 10){//打印10次
                Debug.Log("thread_run2");
                i++;
                Thread.Sleep(3000);
            }
        }
    
        // Update is called once per frame
        void Update () {
            //Debug.Log("zhu xian cheng");//主线程也在运行
        }
    }

    3.运行结果

    线程锁

    线程锁,两个线程是独立的,假设他们要访问同一个变量,访问公共的资源(全局变量),就需要加锁,才能保证数据访问的安全

    两个人都要访问共用的资源,怎样让他们不冲突,如我正在改,你也在改,那到底是改谁的,哪个逻辑是对的。或者我在读,你在改,我读到的到底是你改之前的还是你改之后的,就会有很多不确定性。

    所以,当两个线程来访问公共资源的时候,可以采用锁的结构来解决这个问题,就是说你进来之前先拉一下锁,如果你拿到了这个锁的权利,这时候就你进去访问,其他的线程就会挂起等待,等到你把这个锁释放出来,再继续。

    线程锁案例

    1.创建Unity项目和文件目录,保存场景

    2.创建一个空节点game,再创建一个脚本game挂载在gamej节点下

     打开game脚本

    using System.Collections;
    using System.Collections.Generic;
    using UnityEngine;
    using System.Threading;//多线程要用到的库,多线程对象所在的名字空间
    
    public class game : MonoBehaviour {
    
        // 定义一个静态全局的对象,这个就是锁了
        public static Object o = new Object();
    
        //定义一个静态变量可以被全局访问
        public static int g_a = 3;
    
        // Use this for initialization
        void Start () {
          
            //创建一个线程t1,关联入口函数
            Thread t1 = new Thread(this.thread_run);//不是像协程那样直接运行
            t1.Start();//这里才开始执行,开启线程
    
            //再创建一个线程t2
            Thread t2 = new Thread(this.thread_run2);
            t2.Start();
    
        }
    
        //线程t1的入口函数
        void thread_run(){
            Debug.Log("thread_run wait for lock...");
            lock (o) // 如果没有获得这个锁,那么线程就会挂起等待,只有等他获得了这个锁才会继续往下执行,这个o就是一个锁
            {  // 你获取到了这个锁,开始操作
                Debug.Log("thread_run get lock");
                g_a = 10;
                Debug.Log("g_a = " + g_a);
                Thread.Sleep(20000);//故意让它睡20秒便于观察
                Debug.Log("thread_run release lock");
            } // 括号结束了以后,你就释放了这个锁,其他的线程就有机会获得这个锁
        
        }
    
        //线程t2的入口函数
        void thread_run2(){
           Debug.Log("thread_run2 wait for lock...");
           lock (o) // 如果没有获得这个锁,那么线程就会挂起等待,只有等他获得了这个锁才会继续往下执行,这个o就是一个锁
           {  // 你获取到了这个锁,开始操作
               Debug.Log("thread_run2 get lock");
               g_a = 10;
               Debug.Log("g_a = " + g_a);
               Thread.Sleep(20000);//故意让它睡20秒便于观察
               Debug.Log("thread_run2 release lock");
           } // 括号结束了以后,你就释放了这个锁,其他的线程就有机会获得这个锁
        
        }
    
        // Update is called once per frame
        void Update () {
    
        }
    }

    3.运行结果

    死锁

    死锁,线程A拿了锁A,在等待锁B,线程B拿了锁B,在等待锁A,两个线程彼此都拿了一个锁,我在等你,你在等我,在等待彼此的对方的锁不让步,这就是死锁。

    死锁后很麻烦,要重启Unity。

    死锁案例

    1.创建Unity项目和文件目录,保存场景

    2.创建一个空节点game,再创建一个脚本game挂载在gamej节点下

     打开game脚本

    using System.Collections;
    using System.Collections.Generic;
    using UnityEngine;
    using System.Threading;//多线程要用到的库,多线程对象所在的名字空间
    
    public class game : MonoBehaviour {
    
        /*
         * 死锁: A线程拿了锁A,在等拿锁B;
         * B线程拿了锁B,在等拿锁A;
         * 如果说你一个线程同时要获取多个锁的时候,为了比避免死锁,
         * 你要按照相同的次序来拿;
         */
    
        //定义两个锁,分别为锁A和锁B
        public static Object A = new Object();
        public static Object B = new Object();
        
    
        // Use this for initialization
        void Start () {
          
            //创建一个线程t1,关联入口函数
            Thread t1 = new Thread(this.thread_run);//不是像协程那样直接运行
            t1.Start();//这里才开始执行,开启线程
    
            //再创建一个线程t2
            Thread t2 = new Thread(this.thread_run2);
            t2.Start();
    
        }
    
        //线程t1的入口函数
        void thread_run(){
            lock (A)
            {
                Thread.Sleep(3000);//先休息3秒钟,保证线程2拿到锁B
                Debug.Log("t1 wait for Lock B");
                lock (B)
                {
                    Debug.Log("t1 run");
                }
                Debug.Log("t1 release B");
            }
            Debug.Log("t1 release A");
        }
    
        //线程t2的入口函数
        void thread_run2(){
            //死锁语句
            /*lock (B)
            {
                Thread.Sleep(3000);//先休息3秒钟,保证线程1拿到锁A
                Debug.Log("wait for Lock A");
                lock (A)
                {
                    Debug.Log("run");
                }
                Debug.Log("release A");
            }
            Debug.Log("release B");
            */
    
            //解决死锁的方法
            lock (A)
            {
                Thread.Sleep(3000);
                Debug.Log("t2 wait for Lock B");
                lock (B)
                {
                    Debug.Log("t2 run");
                }
                Debug.Log("t2 release B");
            }
            Debug.Log("t2 release A");
        }
    
        // Update is called once per frame
        void Update () {
    
        }
    }

    3.运行结果

    死锁

    死锁解决

    WWW

    Unity中用来处理HTTP协议相关的,有HTTPget和HTTPpost,WWW就是HTTP封装的一个对象

    1: WWW w = new WWW(url);
    2: WWW(url)会在后台下载url数据;
    3: yeild return w来在协程里等待下载完成;
    4: 完成后可以继续处理;

    5.还可以获取网页其他的内容,数据,表单,图片等等,可以点击WWW类点F12查看。

    WWW案例

    1.创建Unity项目和文件目录,保存场景

    2.创建一个空节点game,再创建一个脚本game挂载在gamej节点下

     打开game脚本

    using System.Collections;
    using System.Collections.Generic;
    using UnityEngine;
    using System.Threading;//多线程要用到的库,多线程对象所在的名字空间
    
    public class game : MonoBehaviour {
    
    
        // Use this for initialization
        void Start () {
          
            //创建一个线程t1,关联入口函数
            Thread t1 = new Thread(this.thread_run);//不是像协程那样直接运行
            t1.Start();//这里才开始执行,开启线程
    
            //再创建一个线程t2
            Thread t2 = new Thread(this.thread_run2);
            t2.Start();
    
            // 启动一个协程去加载网络数据---->捞百度网页
            this.StartCoroutine(this.http_get_baidu());
            Debug.Log("do other");//可以马上做其他的事情,抓百度网站的事情交给协程去做
        }
    
        IEnumerator http_get_baidu()
        {
            // 完成unity http请求和协议;
            WWW w = new WWW("www.baidu.com");
            // 网络需要抓取时间,在后台抓取网络数据,一段时间以后,才能完整的抓完整个数据;
            yield return w;
    
            // 抓取完成网络数据
            Debug.Log(w.text);
            // end 
        }
    
        //线程t1的入口函数
        void thread_run(){
           
        }
    
        //线程t2的入口函数
        void thread_run2(){
         
        }
    
        // Update is called once per frame
        void Update () {
    
        }
    }

    3.运行结果

  • 相关阅读:
    Docker
    Dotted lines by default in ViVA
    8245H(C2)光猫配置方法
    两种将verilog网表转为spice网表的方法
    calibredrv create reference cell
    怎么flatten一个GDS所有层次
    路由器后面访问光猫
    贝尔IPTV
    PDK导出的cdl MOS四端顺序不正确
    如何删除已经存在lib的techfile
  • 原文地址:https://www.cnblogs.com/HangZhe/p/7273227.html
Copyright © 2011-2022 走看看