JobSystem 的 IJobParallelFor 使用

2021-04-20 11:04:30 阅读：194 来源： 互联网

标签：IJobParallelFor Complete 使用 job result JobSystem using NativeArray public

IJobParallelFor 有啥用：
1.IJob 一次只能执行一个任务，如果需要重复执行某个动作很多次，就可以用到并行任务 IJobParallelFor
2.ParallelFor jobs使用 NativeArray作为数据源，并且运行在多个core上，每个job只负责处理完整数据的一个子集Execute(idx)方法对于数据源NativeArray中的每个item都调用一次
3.需要手动执行次数，表示需要分多少次独立Execute执行，一般直接取 NativeArray 的数组长度作为执行次数，一次处理一个数据
4.当一个native job提前完成它的batches，它会从其他的native job偷取一部分batches，然后继续执行

颗粒度问题：
分的太细会有work不断重建开销，分的太粗又会有单核负载问题
（推荐：从1开始逐步增加，知道性能不再提高）

注意事项：
1.不能在job中访问static数据
2.Flush scheduled batchs
====>JobHandle.Complete：直接开始执行。
====>不flush batch会导致调度延迟到主线程等待batch执行结果时才触发执行
3.不要试图更新NativeContainer的内容
====>navtiveArray[0]++
4.主线程在访问数据之前，需要依赖的job调用complete
====>不能只是check JobHandle.IsCompleted，而是需要手动调用JobHandle.Complete()
5.在主线程中使用Schedule和Complete
====>这两个函数只能在主线程中调用。不能因为一个job依赖另一个job，就在前一个job中手动schedule另一个job
6.在正确的时间使用Schedule和Complete
====>Schedule：在数据填充完毕，立马调用
====>Complete：只在你需要result的时候调用
7.NativeContainer添加read-only标记
====>默认是可读写的，如果确定只读就标记为read-only，可以提升性能
8.不要在job里面分配托管内存managed memory
====>在job里面分配托管内存是非常慢的，而且会导致Burst compiler没法使用
====>Burst是基于LLVM的后端编译技术，它可以利用平台特定能力将c# jobs代码编译成高度优化过的机器码

代码如下：

using System.Collections;
using System.Collections.Generic;
using Unity.Collections;
using Unity.Jobs;
using UnityEditor;
using UnityEngine;

public class TestJobParallelFor_1 : MonoBehaviour
{
    public struct MyParallelJob : IJobParallelFor
    {
        public NativeArray<float> a;
        public NativeArray<float> b;
        public NativeArray<float> result;

        public void Execute(int index)
        {
            result[index] = a[index] + b[index];
        }
    }

    void ScheduleParallelJob()
    {
        NativeArray<float> a = new NativeArray<float>(10, Allocator.TempJob);
        NativeArray<float> b = new NativeArray<float>(10, Allocator.TempJob);
        NativeArray<float> result = new NativeArray<float>(10, Allocator.TempJob);

        int dataCount = 10;
        for (int i = 0; i < dataCount; i++)
        {
            a[i] = i * 0.3f;
            b[i] = i * 0.5f;
        }

        MyParallelJob jobData = new MyParallelJob();
        jobData.a = a;
        jobData.b = b;
        jobData.result = result;
        JobHandle handle = jobData.Schedule(dataCount, 1);
        handle.Complete();

        for (int i = 0; i < dataCount; i++)
        {
            Debug.LogError(result[i]);
        }

        a.Dispose();
        b.Dispose();
        result.Dispose();
    }

    private void Update()
    {
        ScheduleParallelJob();
    }
}

标签：IJobParallelFor,Complete,使用,job,result,JobSystem,using,NativeArray,public
来源： https://blog.csdn.net/qq_33064771/article/details/115897209

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

JobSystem 的 IJobParallelFor 使用