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(); } }